auto-sync: 2026-05-18 19:05:51
This commit is contained in:
@@ -720,29 +720,27 @@ class TestE9RealAgentDispatch:
|
||||
from src.blackboard.registry import ProjectRegistry
|
||||
from src.daemon.dispatcher import Dispatcher
|
||||
from src.daemon.spawner import AgentSpawner
|
||||
# 用 tmpdir 做隔离 registry,避免遍历全局旧项目
|
||||
import tempfile
|
||||
tmp = Path(tempfile.mkdtemp(prefix="e2e-ticker-"))
|
||||
registry = ProjectRegistry(tmp)
|
||||
# 把当前项目复制到 tmp
|
||||
self._tmp = Path(tempfile.mkdtemp(prefix="e2e-ticker-"))
|
||||
registry = ProjectRegistry(self._tmp)
|
||||
import shutil
|
||||
src_dir = self.data_root / self.pid
|
||||
dst_dir = tmp / self.pid
|
||||
dst_dir = self._tmp / self.pid
|
||||
if src_dir.exists():
|
||||
shutil.copytree(src_dir, dst_dir)
|
||||
registry.create_project(self.pid, f"E9-{self.pid}")
|
||||
|
||||
spawner = AgentSpawner(dry_run=True) # dry_run 避免真实 spawn
|
||||
self._spawner = AgentSpawner(dry_run=True)
|
||||
dispatcher = Dispatcher(
|
||||
registered_agents=["zhangfei-dev", "jiangwei-infra", "simayi-challenger", "pangtong-fujunshi"],
|
||||
spawner=spawner,
|
||||
spawner=self._spawner,
|
||||
)
|
||||
return Ticker(
|
||||
registry=registry,
|
||||
tick_interval=30,
|
||||
max_dispatch_per_tick=3,
|
||||
dispatcher=dispatcher,
|
||||
spawner=spawner,
|
||||
spawner=self._spawner,
|
||||
)
|
||||
|
||||
def test_e91_simple_task_agent_execute(self, client):
|
||||
|
||||
Reference in New Issue
Block a user