research-pipeline-workflow

Research pipeline workflow

Orchestrates a deployed Mistral Workflow for multi-step research (literature review, competitive analysis, technical deep-dive). Queries hypotheses at each checkpoint, lets the user validate or amend them, and injects additional sources when needed — all via workflow_interact.

Profile note: workflow_execute, workflow_status, and workflow_interact are available in the core profile (default). No additional profile is required for workflow-only orchestration.

Temporal behavior: the workflow status stays RUNNING even when the pipeline is blocked waiting for hypothesis validation (a wait_for_input() pause in the workflow). Detect this state by querying a status handler — do not wait for a PAUSED status, which does not exist in this API.

Important: handler names are workflow-specific

Ask the user (or consult mistral://workflows) for:

• Query handler for progress: e.g. "get_progress"
• Query handler for hypotheses: e.g. "get_hypotheses"
• Signal handler for hypothesis decisions: e.g. "hypothesis_decision"

Steps

Step 1 — Define the research mission

Ask the user for:

1. workflowIdentifier — the deployed research workflow name or ID
2. topic — the research question (be specific)
3. depth — "shallow" (quick scan), "medium" (balanced), "deep" (comprehensive)
4. output_format — "bullets", "report", or "json"
5. Optional: initial source URLs or file_ids to seed the pipeline
6. Handler names (if non-default)

Step 2 — Launch the pipeline

Call workflow_execute:

{
  "workflowIdentifier": "<workflow name or ID>",
  "input": {
    "topic": "<research question>",
    "depth": "medium",
    "output_format": "report",
    "sources": ["<url_or_file_id>"]
  }
}

Note structuredContent.execution_id. Confirm: "Research pipeline started — execution ID: <execution_id>."

Step 3 — Poll and query progress

Loop:

1. Call workflow_status with { "executionId": "<execution_id>" }
2. Check structuredContent.status:
   • COMPLETED → go to Step 5
   • FAILED / TIMED_OUT / CANCELED → surface error and stop
   • RUNNING → continue