fix(entrypoint): start the celery worker only when CELERY_BULK_ENABLED=true — a misconfigured rediss:// broker caused a pointless 5s crash-restart loop while bulk actually runs sync

entrypoint.py

@@ -208,8 +208,22 @@ def main():
     signal.signal(signal.SIGTERM, on_signal)
     signal.signal(signal.SIGINT, on_signal)
 
-    if broker_url:
+    # Celery worker (bulk validation queue) starts ONLY when bulk is routed
+    # through Celery on this host. With CELERY_BULK_ENABLED=false (the Space
+    # default) bulk runs synchronously in-process, and spawning a worker
+    # against a misconfigured broker (e.g. a rediss:// URL without
+    # ssl_cert_reqs) produced a pointless 5s crash-restart loop.
+    run_celery_worker = (
+        os.environ.get("CELERY_BULK_ENABLED", "").strip().lower() in ("1", "true", "yes")
+    )
+    if broker_url and run_celery_worker:
         spawn("worker")
+    elif broker_url:
+        print(
+            "[ENTRYPOINT] CELERY_BULK_ENABLED!=true — bulk runs sync; "
+            "celery worker NOT started",
+            flush=True,
+        )
     web = spawn("web")
 
     while not state["stopping"]:
@@ -221,7 +235,7 @@ def main():
             time.sleep(2)
             if not state["stopping"]:
                 spawn("redis")
-        if broker_url and children["worker"].poll() is not None:
+        if run_celery_worker and broker_url and children.get("worker") and children["worker"].poll() is not None:
             print(f"[ENTRYPOINT] worker exited ({children['worker'].returncode}) - restarting in 5s", flush=True)
             time.sleep(5)
             if not state["stopping"]: