feat: add POST /tasks/pipeline endpoint for background pipeline execution

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: michaelchu

src/server/handlers/tasks.rs

@@ -17,7 +17,7 @@ use std::sync::atomic::Ordering;
 use std::sync::Arc;
 
 use crate::application::error::{ApplicationError, ApplicationErrorKind};
-use crate::application::{backtests, sweeps, tasks as app_tasks, workflows};
+use crate::application::{backtests, pipeline, sweeps, tasks as app_tasks, workflows};
 use crate::engine::walk_forward::{WalkForwardParams, WfMode, WfObjective};
 use crate::scripting::engine::CachingDataLoader;
 use crate::server::state::AppState;
@@ -302,6 +302,67 @@ pub async fn submit_sweep(
     Ok(Json(SubmitResponse { task_id }))
 }
 
+/// `POST /tasks/pipeline` — Submit a full pipeline task (sweep + gates + WF + MC).
+#[allow(clippy::unused_async)]
+pub async fn submit_pipeline(
+    State(state): State<AppState>,
+    Json(req): Json<SubmitSweepRequest>,
+) -> Result<Json<SubmitResponse>, (StatusCode, String)> {
+    let symbol = req
+        .params
+        .get("symbol")
+        .and_then(Value::as_str)
+        .unwrap_or("pending")
+        .to_owned();
+
+    let params_json =
+        serde_json::to_value(&req.params).unwrap_or(Value::Object(serde_json::Map::default()));
+
+    let task = state.task_manager.register(
+        TaskKind::Sweep,
+        &req.strategy,
+        &symbol,
+        req.thread_id.clone(),
+        params_json,
+    );
+    let task_id = task.id.clone();
+
+    let tm = Arc::clone(&state.task_manager);
+    let server = state.server.clone();
+    tokio::spawn(async move {
+        Box::pin(app_tasks::execute_queued_task(
+            tm,
+            Arc::clone(&task),
+            async move {
+                let pipeline_req = pipeline::PipelineRequest {
+                    strategy: req.strategy,
+                    mode: req.mode,
+                    objective: req.objective,
+                    params: req.params,
+                    sweep_params: req.sweep_params,
+                    max_evaluations: req.max_evaluations,
+                    num_permutations: req.num_permutations,
+                    thread_id: req.thread_id,
+                };
+
+                let result = pipeline::execute(&server, &pipeline_req, "manual")
+                    .await
+                    .map_err(|e| e.to_string())?;
+
+                let result_json = serde_json::to_value(&result).unwrap_or(Value::Null);
+
+                Ok(app_tasks::TaskCompletion {
+                    result_json,
+                    result_id: result.sweep_id,
+                })
+            },
+        ))
+        .await;
+    });
+
+    Ok(Json(SubmitResponse { task_id }))
+}
+
 /// `POST /tasks/walk-forward` — Submit a walk-forward validation task.
 #[allow(clippy::unused_async, clippy::too_many_lines)]
 pub async fn submit_walk_forward(

src/server/router.rs

@@ -8,8 +8,8 @@ use axum::Router;
 use tower_http::cors::CorsLayer;
 
 use crate::server::handlers::{
-    backtests, chat as chat_handlers, forward_tests, pipeline, profiles, runs, strategies, sweeps,
-    tasks,
+    backtests, chat as chat_handlers, forward_tests, hypotheses, pipeline, profiles, runs,
+    strategies, sweeps, tasks,
 };
 use crate::server::state::AppState;
 
@@ -77,6 +77,13 @@ pub fn build_api_router(state: AppState) -> Router {
         )
         .with_state(state.clone());
 
+    let analysis_routes = Router::new()
+        .route(
+            "/hypotheses",
+            axum::routing::post(hypotheses::generate_hypotheses),
+        )
+        .with_state(state.clone());
+
     let misc_routes = Router::new()
         .route("/profiles", axum::routing::get(profiles::list_profiles))
         .route("/health", axum::routing::get(|| async { "ok" }))
@@ -137,6 +144,10 @@ pub fn build_api_router(state: AppState) -> Router {
             axum::routing::post(tasks::submit_backtest),
         )
         .route("/tasks/sweep", axum::routing::post(tasks::submit_sweep))
+        .route(
+            "/tasks/pipeline",
+            axum::routing::post(tasks::submit_pipeline),
+        )
         .route(
             "/tasks/walk-forward",
             axum::routing::post(tasks::submit_walk_forward),
@@ -180,6 +191,7 @@ pub fn build_api_router(state: AppState) -> Router {
         .merge(run_routes)
         .merge(task_routes)
         .merge(forward_test_routes)
+        .merge(analysis_routes)
         .merge(misc_routes)
         .layer(CorsLayer::permissive())
 }