|
|
@@ -211,6 +211,19 @@ async def _run_local_agent(
|
|
|
skills_dir=skills_dir,
|
|
|
)
|
|
|
|
|
|
+ # Local SDK composition root for explicit-validation projects.
|
|
|
+ from agent.orchestration.models import CompletionPolicy
|
|
|
+ if CompletionPolicy(run_config.completion_policy) == CompletionPolicy.EXPLICIT_VALIDATION:
|
|
|
+ from agent.orchestration.config import OrchestrationConfig
|
|
|
+ from agent.orchestration.store import FileSystemArtifactStore, FileSystemTaskStore
|
|
|
+ from agent.orchestration.wiring import wire_orchestration
|
|
|
+ wire_orchestration(
|
|
|
+ runner,
|
|
|
+ FileSystemTaskStore(trace_store_path),
|
|
|
+ FileSystemArtifactStore(trace_store_path),
|
|
|
+ getattr(cfg_mod, "ORCHESTRATION_CONFIG", OrchestrationConfig()),
|
|
|
+ )
|
|
|
+
|
|
|
# 7. 构建消息
|
|
|
msgs = list(messages) if messages else []
|
|
|
msgs.append({"role": "user", "content": task})
|