zhaoxi
/
Pretor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: 修复了逻辑

This commit is contained in:
朝夕 2026-04-28 15:18:35 +08:00
parent 0ee8139902
commit 71ede0ac69
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
main.py
View File

@ -1,6 +1,6 @@
import asyncio import asyncio
import ray import ray
from pretor.worker_individual.worker_cluster import WorkerCluster
from pretor.utils.banner import print_banner from pretor.utils.banner import print_banner
from pretor.core.database.postgres import PostgresDatabase from pretor.core.database.postgres import PostgresDatabase
from pretor.core.global_state_machine.global_state_machine import GlobalStateMachine from pretor.core.global_state_machine.global_state_machine import GlobalStateMachine
@ -56,6 +56,14 @@ async def start_system():
consciousness_node = ConsciousnessNode.options(name='consciousness_node').remote() consciousness_node = ConsciousnessNode.options(name='consciousness_node').remote()
control_node = ControlNode.options(name='control_node').remote() control_node = ControlNode.options(name='control_node').remote()
try:
worker_cluster_actor = WorkerCluster.options(
name="worker_cluster",
lifetime="detached" # 保证它在后台一直运行
).remote()
print("✅ WorkerCluster 已成功启动并注册！")
except ValueError:
print("WorkerCluster 已经存在。")
# 5. 启动工作流运行引擎 # 5. 启动工作流运行引擎
workflow_engine = WorkflowRunningEngine.options(name='workflow_running_engine').remote( workflow_engine = WorkflowRunningEngine.options(name='workflow_running_engine').remote(
consciousness_node=consciousness_node, consciousness_node=consciousness_node,