from app.tasks.celery_app import celery_app

@celery_app.task(bind=True, autoretry_for=(Exception,), retry_backoff=True, max_retries=3)
def send_campaign_job(self, campaign_id: int):
    return {"campaign_id": campaign_id, "status": "queued-demo"}

@celery_app.task
def expire_points_job():
    return {"status": "completed"}