diff --git a/start_unified.py b/start_unified.py index 270b94b..5df609c 100755 --- a/start_unified.py +++ b/start_unified.py @@ -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 ]