Run a workflow from the builder

# 1. Start the run (returns immediately with a run_id)
curl -X POST https://api.modulex.dev/workflows/run \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 11111111-1111-1111-1111-111111111111" \
  -H "Content-Type: application/json" \
  -d '{
    "workflow_id": "550e8400-e29b-41d4-a716-446655440000",
    "input": {"query": "AI trends"},
    "config": {"recursion_limit": 50}
  }'

# 2. Stream the run live (data-only SSE; discriminate on the JSON "type")
curl -N https://api.modulex.dev/workflows/listen/6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 11111111-1111-1111-1111-111111111111"

import asyncio
from modulex import AsyncModulex, NotFoundError

client = AsyncModulex(api_key="mx_live_xxx", organization_id="11111111-1111-1111-1111-111111111111")

async def main():
    run = await client.executions.run(
        workflow_id="550e8400-e29b-41d4-a716-446655440000",
        input={"query": "AI trends"},
        idempotency_key="research-4823",   # safe to retry the start call
    )
    print(run.run_id, run.status)

    try:
        async for event in client.executions.listen(run.run_id):
            if event.event == "node_update":
                print(event.data["node"], event.data.get("output"))
            elif event.is_terminal:
                break
    except NotFoundError:
        # A run your org does not own returns 404 on connect — do not reconnect.
        print("Run not found or not owned by this organization.")

asyncio.run(main())

import Modulex from "modulex";

const client = new Modulex({
  apiKey: "mx_live_xxx",
  organizationId: "11111111-1111-1111-1111-111111111111",
});

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

for await (const event of client.executions.listen(run.run_id)) {
  if (event.type === "node_update") console.log(event.node, event.output); // flat frame
  if (event.type === "done") console.log("finished:", event.data.message); // wrapped frame
  if (event.type === "error") console.error(event.message);
}