Optimization

# 1. Start the run (returns immediately with a run_id)
curl -X POST 'https://api.modulex.dev/workflows/run' \
  -H 'Authorization: Bearer mx_live_...' \
  -H 'X-Organization-ID: org_2ab9f1c4' \
  -H 'Content-Type: application/json' \
  -d '{"workflow_id": "wf_7d2e1a", "input": {"topic": "release notes"}}'

# 2. Attach to the live stream (data: <json>\n\n frames; switch on the JSON "type")
curl -N 'https://api.modulex.dev/workflows/listen/6a7b8c9d-1e2f-3a4b-5c6d-7e8f9a0b1c2d' \
  -H 'Authorization: Bearer mx_live_...' \
  -H 'X-Organization-ID: org_2ab9f1c4'

import asyncio
from modulex import Modulex

async def main():
    async with Modulex(api_key="mx_live_...", organization_id="org_2ab9f1c4") as client:
        run = await client.executions.run(
            workflow_id="wf_7d2e1a",
            input={"topic": "release notes"},
        )
        # Stream events for the same run_id until a terminal event arrives.
        async for event in client.executions.listen(run["run_id"]):
            print(event.event, event.data)

asyncio.run(main())

import { Modulex } from 'modulex-js';

const client = new Modulex({
  apiKey: 'mx_live_...',
  organizationId: 'org_2ab9f1c4',
});

const run = await client.executions.run({
  workflowId: 'wf_7d2e1a',
  input: { topic: 'release notes' },
});

// Stream events for the same run_id until a terminal event arrives.
for await (const event of client.executions.listen(run.run_id)) {
  console.log(event.type, event.data);
}