fix: document single-instance constraint for embedded Beat & optimize synchronize_session

- entrypoint-worker.sh: prominent deployment constraint warning (replicas=1 only) - generation_task_repository.py: synchronize_session=False for cleanup (no post-update session sync needed)
2026-08-23 12:44:50 +08:00
parent 1712c1693a
commit 498b490bac
2 changed files with 5 additions and 3 deletions
@@ -6,8 +6,10 @@ set -e

 CONCURRENCY="${WORKER_CONCURRENCY:-2}"

-# 启用 -B 标志嵌入 celery beat（单 worker 实例，足够安全）
-# beat 负责定期触发 pending 超时清理等定时任务
+# ⚠️ 部署约束：此 Worker 必须且只能运行单实例（replicas=1）
+# -B 标志嵌入 celery beat，beat 负责定期触发 pending 超时清理等定时任务
+# 多实例部署会导致每个 Worker 独立运行 Beat，造成定时任务重复执行
+# 若需横向扩展 Worker，必须将 Beat 拆分为独立服务（celery beat -A worker_app.celery_app）
 exec celery \
  -A worker_app.celery_app \
  worker \
@@ -344,7 +344,7 @@ class SQLAlchemyGenerationTaskRepository:
                    GenerationTaskModel.error_info: error_info,
                    GenerationTaskModel.completed_at: datetime.now(timezone.utc),
                },
-                synchronize_session="fetch",
+                synchronize_session=False,
            )
        )
        self.session.commit()