opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-05-09 04:36:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

minor fix the impl of dify-agent worker

Browse Source
This commit is contained in:
盐粒 Yanli 2026-05-08 01:36:54 +08:00
parent a523d071ca
commit 2a5601e868
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dify-agent/src/dify_agent/worker/job_worker.py
View File

@ -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()