diff options
Diffstat (limited to 'makima/src/server')
| -rw-r--r-- | makima/src/server/handlers/mesh_supervisor.rs | 41 |
1 files changed, 8 insertions, 33 deletions
diff --git a/makima/src/server/handlers/mesh_supervisor.rs b/makima/src/server/handlers/mesh_supervisor.rs index 90c6dc7..0ea1a57 100644 --- a/makima/src/server/handlers/mesh_supervisor.rs +++ b/makima/src/server/handlers/mesh_supervisor.rs @@ -1807,42 +1807,17 @@ pub async fn ask_question( ).into_response(); } - // If phaseguard is enabled (or directive reconcile mode), pause the supervisor task and return - // The task will be auto-resumed when a message is sent to it (e.g., when user answers) + // Determine if we should block indefinitely (phaseguard or directive reconcile mode) let use_phaseguard = request.phaseguard || (is_directive_context && directive_reconcile_mode); - if use_phaseguard { - // Pause the supervisor task - if let Some(daemon_id) = supervisor.daemon_id { - let cmd = DaemonCommand::PauseTask { task_id: supervisor_id }; - if let Err(e) = state.send_daemon_command(daemon_id, cmd).await { - tracing::warn!(supervisor_id = %supervisor_id, error = %e, "Failed to pause supervisor for phaseguard"); - } else { - tracing::info!(supervisor_id = %supervisor_id, "Paused supervisor for phaseguard question"); - } - } - - // Update task status to paused in DB - let update = crate::db::models::UpdateTaskRequest { - status: Some("paused".to_string()), - ..Default::default() - }; - if let Err(e) = repository::update_task_for_owner(pool, supervisor_id, owner_id, update).await { - tracing::warn!(supervisor_id = %supervisor_id, error = %e, "Failed to update task status to paused"); - } - - return ( - StatusCode::OK, - Json(AskQuestionResponse { - question_id, - response: None, - timed_out: false, - }), - ).into_response(); - } // Poll for response with timeout - // For directive tasks without reconcile mode, use 30s default timeout - let timeout_secs = if is_directive_context && !directive_reconcile_mode { + // - Phaseguard: block indefinitely until user responds + // - Directive tasks without reconcile mode: 30s default timeout + // - Contract tasks: use requested timeout_seconds + let timeout_secs = if use_phaseguard { + // Block indefinitely until user responds + u64::MAX / 2 + } else if is_directive_context && !directive_reconcile_mode { 30 } else { request.timeout_seconds.max(1) as u64 |
