How ModuleX works

# 1. Start the run
curl -X POST https://api.modulex.dev/workflows/run \
  -H "Authorization: Bearer mx_live_2f9c4a1b8e7d6c5a4b3f2e1d0c9b8a76" \
  -H "X-Organization-ID: 8a1f3c2e-9b4d-4e7a-bc11-7d6e5f4a3b2c" \
  -H "Content-Type: application/json" \
  -d '{"workflow_id": "wf_3d8b9a1c-2e4f-4a6b-8c0d-1e2f3a4b5c6d", "input": {"topic": "weekly sales summary"}}'
# → {"status":"running","run_id":"6a7b...","thread_id":"550e...","chat_id":"..."}

# 2. Observe the run (SSE stream of events until a terminal one)
curl -N https://api.modulex.dev/workflows/listen/6a7b8c9d-0e1f-2a3b-4c5d-6e7f8a9b0c1d \
  -H "Authorization: Bearer mx_live_2f9c4a1b8e7d6c5a4b3f2e1d0c9b8a76" \
  -H "X-Organization-ID: 8a1f3c2e-9b4d-4e7a-bc11-7d6e5f4a3b2c"

import asyncio
from modulex import Modulex


async def main():
    async with Modulex(
        api_key="mx_live_2f9c4a1b8e7d6c5a4b3f2e1d0c9b8a76",
        organization_id="8a1f3c2e-9b4d-4e7a-bc11-7d6e5f4a3b2c",
    ) as client:
        # 1. Start the run
        run = await client.executions.run(
            workflow_id="wf_3d8b9a1c-2e4f-4a6b-8c0d-1e2f3a4b5c6d",
            input={"topic": "weekly sales summary"},
        )

        # 2. Observe the run, event by event
        async with client.executions.listen(run.run_id) as stream:
            async for event in stream:
                print(event.event)
                if event.is_terminal:
                    break


asyncio.run(main())

import { Modulex } from "modulex-js";

const client = new Modulex({
  apiKey: "mx_live_2f9c4a1b8e7d6c5a4b3f2e1d0c9b8a76",
  organizationId: "8a1f3c2e-9b4d-4e7a-bc11-7d6e5f4a3b2c",
});

// 1. Start the run
const run = await client.executions.run({
  workflowId: "wf_3d8b9a1c-2e4f-4a6b-8c0d-1e2f3a4b5c6d",
  input: { topic: "weekly sales summary" },
});

// 2. Observe the run, event by event
for await (const event of client.executions.listen(run.runId)) {
  console.log(event.type);
  if (event.type === "done" || event.type === "error" || event.type === "cancelled") {
    break;
  }
}