Update app/routers/deliver.py

app/routers/deliver.py

@@ -3,11 +3,10 @@ from sqlalchemy.orm import Session
 from app.database import get_db
 from app import models
 from app.tasks import task_deliver
-
+from app.config import settings
 
 router = APIRouter(prefix="/deliver", tags=["deliver"])
 
-
 @router.post("/{draft_id}")
 async def deliver_now(draft_id: int, db: Session = Depends(get_db)):
     draft = db.get(models.Draft, draft_id)
@@ -15,5 +14,11 @@ async def deliver_now(draft_id: int, db: Session = Depends(get_db)):
         return {"error": "not found"}
     if draft.status not in [models.DraftStatus.approved, models.DraftStatus.scheduled]:
         return {"error": f"status must be approved/scheduled, current={draft.status.value}"}
-    task_deliver.delay(draft.id)
-    return {"ok": True, "queued": True}
+
+    if settings.CELERY_BROKER_URL:
+        task_deliver.delay(draft.id)
+        return {"ok": True, "queued": True}
+    else:
+        # inline for demo; real env should use worker
+        res = task_deliver(draft.id)
+        return {"ok": True, "queued": False, "result": res}