diff options
Diffstat (limited to 'makima/src/server/handlers/mesh_daemon.rs')
| -rw-r--r-- | makima/src/server/handlers/mesh_daemon.rs | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/makima/src/server/handlers/mesh_daemon.rs b/makima/src/server/handlers/mesh_daemon.rs index beb4c15..767d059 100644 --- a/makima/src/server/handlers/mesh_daemon.rs +++ b/makima/src/server/handlers/mesh_daemon.rs @@ -1303,7 +1303,16 @@ async fn handle_daemon_connection(socket: WebSocket, state: SharedState, auth_re }), ).await; - // TODO: Directive engine integration (removed for reimplementation) + // Directive engine integration + if let Err(e) = crate::orchestration::directive::on_task_completed( + &pool, &state, &updated_task, owner_id, + ).await { + tracing::warn!( + task_id = %task_id, + error = %e, + "Failed to process directive task completion" + ); + } } Ok(None) => { tracing::warn!( |