From 2a5601e86843c2c787f8065c788a1eda830dc35e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=9B=90=E7=B2=92=20Yanli?= Date: Fri, 8 May 2026 01:36:54 +0800 Subject: [PATCH] minor fix the impl of dify-agent worker --- dify-agent/src/dify_agent/worker/job_worker.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/dify-agent/src/dify_agent/worker/job_worker.py b/dify-agent/src/dify_agent/worker/job_worker.py index 4f2c7bb6d4..0a8bb2175f 100644 --- a/dify-agent/src/dify_agent/worker/job_worker.py +++ b/dify-agent/src/dify_agent/worker/job_worker.py @@ -53,7 +53,7 @@ class RunJobWorker: store: RedisRunStore, group_name: str = "run-workers", consumer_name: str = "worker-1", - pending_idle_ms: int = 60_000, + pending_idle_ms: int = 600_000, runner_factory: JobRunnerFactory | None = None, ) -> None: self.store = store @@ -141,7 +141,12 @@ async def main() -> None: settings = ServerSettings() redis = Redis.from_url(settings.redis_url) try: - await RunJobWorker(store=RedisRunStore(redis, prefix=settings.redis_prefix)).run_forever() + await RunJobWorker( + store=RedisRunStore(redis, prefix=settings.redis_prefix), + group_name=settings.worker_group_name, + consumer_name=settings.worker_consumer_name or "worker-1", + pending_idle_ms=settings.worker_pending_idle_ms, + ).run_forever() finally: await redis.aclose()