Merge branch 'developing' into dev

This commit is contained in:
朱潮 2026-04-29 17:04:18 +08:00
commit 144907f04c

View File

@ -82,10 +82,14 @@ class ProcessManager:
"""启动队列消费者"""
print("正在启动队列消费者...")
consumer_script = Path("task_queue/consumer.py")
if not consumer_script.exists():
consumer_script = consumer_script.with_suffix(".pyc")
# 构建队列消费者命令
cmd = [
sys.executable,
"task_queue/consumer.py",
str(consumer_script),
"--workers", str(args.queue_workers),
"--worker-type", args.worker_type
]