diff options
| author | soryu <soryu@soryu.co> | 2026-02-07 00:01:50 +0000 |
|---|---|---|
| committer | soryu <soryu@soryu.co> | 2026-02-07 00:01:50 +0000 |
| commit | b8d563d45f14a2b1db1f684aa0a8dcd7e5b6ad56 (patch) | |
| tree | 95543fd150270018e384fbcf9d3df3dc45f052f6 /makima/src/server/handlers/mesh_daemon.rs | |
| parent | cececbf326e258211ceae7afce716a5d1e46014f (diff) | |
| download | soryu-b8d563d45f14a2b1db1f684aa0a8dcd7e5b6ad56.tar.gz soryu-b8d563d45f14a2b1db1f684aa0a8dcd7e5b6ad56.zip | |
Remove directives for reimplementation
Diffstat (limited to 'makima/src/server/handlers/mesh_daemon.rs')
| -rw-r--r-- | makima/src/server/handlers/mesh_daemon.rs | 15 |
1 files changed, 1 insertions, 14 deletions
diff --git a/makima/src/server/handlers/mesh_daemon.rs b/makima/src/server/handlers/mesh_daemon.rs index 9938145..beb4c15 100644 --- a/makima/src/server/handlers/mesh_daemon.rs +++ b/makima/src/server/handlers/mesh_daemon.rs @@ -1303,20 +1303,7 @@ async fn handle_daemon_connection(socket: WebSocket, state: SharedState, auth_re }), ).await; - // Check if this task's contract is a directive orchestrator - if let Some(contract_id) = updated_task.contract_id { - if let Ok(Some(directive)) = repository::get_directive_by_orchestrator_contract_id( - &pool, contract_id - ).await { - let engine = crate::orchestration::DirectiveEngine::new(pool.clone()); - if let Err(e) = engine.on_planning_complete(directive.id, success).await { - tracing::error!( - "Failed to handle planning completion for directive {}: {}", - directive.id, e - ); - } - } - } + // TODO: Directive engine integration (removed for reimplementation) } Ok(None) => { tracing::warn!( |