Trigger a workflow run over the API

curl -X POST https://api.modulex.dev/workflows/run \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c" \
  -H "Content-Type: application/json" \
  -d '{
    "workflow_id": "550e8400-e29b-41d4-a716-446655440000",
    "input": { "query": "AI trends 2026" },
    "config": { "recursion_limit": 50 }
  }'

import asyncio
from modulex import Modulex

async def main():
    async with Modulex(
        api_key="mx_live_xxx",
        organization_id="6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c",
    ) as client:
        run = await client.executions.run(
            workflow_id="550e8400-e29b-41d4-a716-446655440000",
            input={"query": "AI trends 2026"},
            config={"recursion_limit": 50},
        )
        print(run.status, run.run_id, run.thread_id)

asyncio.run(main())

import { Modulex } from "modulex-js";

const client = new Modulex({
  apiKey: "mx_live_xxx",
  organizationId: "6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c",
});

const run = await client.executions.run({
  workflowId: "550e8400-e29b-41d4-a716-446655440000",
  input: { query: "AI trends 2026" },
  config: { recursion_limit: 50 },
});
console.log(run.status, run.run_id, run.thread_id);

curl -N https://api.modulex.dev/workflows/listen/6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c" \
  -H "Accept: text/event-stream"

import asyncio
from modulex import Modulex

async def main():
    async with Modulex(
        api_key="mx_live_xxx",
        organization_id="6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c",
    ) as client:
        run = await client.executions.run(
            workflow_id="550e8400-e29b-41d4-a716-446655440000",
            input={"query": "AI trends 2026"},
        )
        async with client.executions.listen(run.run_id) as stream:
            async for event in stream:
                print(event.event, event.data)
                if event.is_terminal:          # done / error / cancelled / interrupted
                    break

asyncio.run(main())

import { Modulex } from "modulex-js";

const client = new Modulex({
  apiKey: "mx_live_xxx",
  organizationId: "6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c",
});

const run = await client.executions.run({
  workflowId: "550e8400-e29b-41d4-a716-446655440000",
  input: { query: "AI trends 2026" },
});

for await (const evt of client.executions.listen(run.run_id)) {
  if (evt.type === "node_update") console.log(evt.node, evt.output);
  if (evt.type === "done" || evt.type === "error") break;
}

curl -X POST https://api.modulex.dev/workflows/resume/550e8400-e29b-41d4-a716-446655440000 \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c" \
  -H "Content-Type: application/json" \
  -d '{
    "workflow_id": "550e8400-e29b-41d4-a716-446655440000",
    "run_id": "6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d",
    "resume_value": { "approved": true }
  }'

await client.executions.resume(
    "550e8400-e29b-41d4-a716-446655440000",      # thread_id
    "6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d",      # run_id (reused)
    {"approved": True},                           # resume_value
    workflow_id="550e8400-e29b-41d4-a716-446655440000",
)

await client.executions.resume({
  threadId: "550e8400-e29b-41d4-a716-446655440000",
  runId: "6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d",  // reused
  resumeValue: { approved: true },
  workflowId: "550e8400-e29b-41d4-a716-446655440000",
});

curl -X POST https://api.modulex.dev/workflows/cancel/6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c" \
  -H "Content-Type: application/json" \
  -d '{"reason": "user_requested"}'

await client.executions.cancel(
    "6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d",
    reason="user_requested",
)

await client.executions.cancel("6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d", {
  reason: "user_requested",
});

import asyncio
from modulex import Modulex

WORKFLOW_ID = "550e8400-e29b-41d4-a716-446655440000"

async def main():
    async with Modulex(
        api_key="mx_live_xxx",
        organization_id="6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c",
    ) as client:
        run = await client.executions.run(
            workflow_id=WORKFLOW_ID,
            input={"query": "AI trends 2026"},
            config={"recursion_limit": 50},
        )
        run_id, thread_id = run.run_id, run.thread_id

        paused = None
        async with client.executions.listen(run_id) as stream:
            async for event in stream:
                if event.event == "node_update":
                    print("node:", event.data.get("node"))
                elif event.event == "interrupt":
                    paused = event.data          # render the prompt to a human
                    break
                elif event.is_terminal:
                    break

        if paused is not None:
            # Answer the interrupt; the SAME run_id continues
            await client.executions.resume(
                thread_id, run_id, {"approved": True}, workflow_id=WORKFLOW_ID,
            )
            async with client.executions.listen(run_id) as stream:
                async for event in stream:
                    if event.is_terminal:
                        break

        # Read the durable outcome from history (run_pk is the record's id, not run_id)
        history = await client.executions.list_runs(workflow_id=WORKFLOW_ID, limit=1)
        latest = history.runs[0]
        detail = await client.executions.get_run(latest.id)
        print(detail.status, detail.output_summary)

asyncio.run(main())

import { Modulex } from "modulex-js";

const WORKFLOW_ID = "550e8400-e29b-41d4-a716-446655440000";

const client = new Modulex({
  apiKey: "mx_live_xxx",
  organizationId: "6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c",
});

const run = await client.executions.run({
  workflowId: WORKFLOW_ID,
  input: { query: "AI trends 2026" },
  config: { recursion_limit: 50 },
});

let paused = null;
for await (const evt of client.executions.listen(run.run_id)) {
  if (evt.type === "node_update") console.log("node:", evt.node);
  else if (evt.type === "interrupt") { paused = evt.data; break; } // render to a human
  else if (evt.type === "done" || evt.type === "error") break;
}

if (paused) {
  // Answer the interrupt; the SAME run_id continues
  await client.executions.resume({
    threadId: run.thread_id,
    runId: run.run_id,
    resumeValue: { approved: true },
    workflowId: WORKFLOW_ID,
  });
  for await (const evt of client.executions.listen(run.run_id)) {
    if (evt.type === "done" || evt.type === "error") break;
  }
}

// Read the durable outcome from history (run_pk is the record's id, not run_id)
const { runs } = await client.workflowRuns.list({ workflowId: WORKFLOW_ID, limit: 1 });
const detail = await client.workflowRuns.get(runs[0].id);
console.log(detail.status, detail.output_summary);

# 1. Trigger
RUN=$(curl -s -X POST https://api.modulex.dev/workflows/run \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c" \
  -H "Content-Type: application/json" \
  -d '{"workflow_id":"550e8400-e29b-41d4-a716-446655440000","input":{"query":"AI trends 2026"}}')
RUN_ID=$(echo "$RUN" | jq -r .run_id)

# 2. Stream until a terminal (done/error) or interrupt frame
curl -N "https://api.modulex.dev/workflows/listen/$RUN_ID" \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c" \
  -H "Accept: text/event-stream"

# 3. If an interrupt arrived, resume on the same run_id (thread_id from step 1)
curl -X POST "https://api.modulex.dev/workflows/resume/550e8400-e29b-41d4-a716-446655440000" \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 6f1c2a4e-0b2d-4a8e-9c3f-1d2e3f4a5b6c" \
  -H "Content-Type: application/json" \
  -d "{\"workflow_id\":\"550e8400-e29b-41d4-a716-446655440000\",\"run_id\":\"$RUN_ID\",\"resume_value\":{\"approved\":true}}"