Pipeline Endpoints

abstract

Read-only view of multi-agent pipeline execution history — list runs and inspect individual run step traces, timing, and LLM outputs for debugging AI decision chains.

🔒 Authentication

PropertyValue
MechanismNone
RequiredNo

Endpoints in this group (2 total)

MethodPathDescription
GET/api/v1/pipeline/runsList recent pipeline runs
GET/api/v1/pipeline/runs/{run_id}Get run detail with all steps

GET /api/v1/pipeline/runs

Returns summary of recent pipeline executions for the active account.

Request

ParameterLocationTypeRequiredDescription
account_idQueryintegerNoFilter by account
symbolQuerystringNoFilter by symbol
limitQueryintegerNoMax results (default: 50)

200 OK example:

[
  {
    "id": 991,
    "account_id": 42,
    "symbol": "EURUSD",
    "timeframe": "H1",
    "task_type": "signal",
    "status": "completed",
    "final_action": "BUY",
    "total_duration_ms": 12450,
    "created_at": "2026-05-16T14:00:00Z"
  }
]

Pydantic Schema: backend/api/routes/pipeline.py :: PipelineRunSummary

GET /api/v1/pipeline/runs/

Full detail including all steps with input/output JSON — for debugging AI reasoning.

200 OK example:

{
  "id": 991,
  "status": "completed",
  "final_action": "BUY",
  "steps": [
    {
      "seq": 1,
      "step_name": "indicator_agent",
      "status": "ok",
      "duration_ms": 3200,
      "output_json": "{\"rsi\": 42.5, \"macd\": \"bullish\", \"verdict\": \"BUY\"}",
      "error": null
    },
    {
      "seq": 2,
      "step_name": "trend_agent",
      "status": "ok",
      "duration_ms": 4100,
      "output_json": "{\"htf_trend\": \"uptrend\", \"verdict\": \"BUY\"}",
      "error": null
    }
  ]
}

Pydantic Schema: backend/api/routes/pipeline.py :: PipelineRunDetail

RolePath
Routerbackend/api/routes/pipeline.py
DB TableDB - pipeline_runs
DB TableDB - pipeline_steps
RoleLink
Frontend PagePage - Agent Workflow
DB SchemaDB - pipeline_runs
DB SchemaDB - pipeline_steps