Make your first API call

pip install modulex-python

npm install modulex-js

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": "Summarize this week'\''s AI news" },
    "config": { "recursion_limit": 50 }
  }'

import asyncio
from modulex import Modulex


async def main():
    async with Modulex(
        api_key="mx_live_xxx",
        organization_id="11111111-1111-1111-1111-111111111111",
    ) as client:
        run = await client.executions.run(
            workflow_id="550e8400-e29b-41d4-a716-446655440000",
            input={"query": "Summarize this week's AI news"},
            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: "11111111-1111-1111-1111-111111111111",
});

const run = await client.executions.run({
  workflowId: "550e8400-e29b-41d4-a716-446655440000",
  input: { query: "Summarize this week's AI news" },
  config: { recursionLimit: 50 },
});

console.log(run.status, run.run_id, run.thread_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": {
      "metadata": { "name": "Ad-hoc research", "version": "1.0" },
      "state_schema": { "fields": { "query": { "type": "string" } } },
      "nodes": [],
      "edges": [],
      "entry_point": "__start__"
    },
    "input": { "query": "Summarize this week'\''s AI news" }
  }'

run = await client.executions.run(
    workflow={
        "metadata": {"name": "Ad-hoc research", "version": "1.0"},
        "state_schema": {"fields": {"query": {"type": "string"}}},
        "nodes": [],
        "edges": [],
        "entry_point": "__start__",
    },
    input={"query": "Summarize this week's AI news"},
)

const run = await client.executions.run({
  workflow: {
    metadata: { name: "Ad-hoc research", version: "1.0" },
    state_schema: { fields: { query: { type: "string" } } },
    nodes: [],
    edges: [],
    entry_point: "__start__",
  },
  input: { query: "Summarize this week's AI news" },
});

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"

async with client.executions.listen(run.run_id) as stream:
    async for event in stream:
        if event.event == "node_update":
            print("node", event.data.get("node"), "→", event.data.get("output"))
        if event.is_terminal:
            print("finished:", event.event)
            break

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

# List recent runs for a workflow
curl https://api.modulex.dev/workflow-runs?workflow_id=550e8400-e29b-41d4-a716-446655440000&limit=10 \
  -H "Authorization: Bearer mx_live_xxx" \
  -H "X-Organization-ID: 11111111-1111-1111-1111-111111111111"

runs = await client.executions.list_runs(
    workflow_id="550e8400-e29b-41d4-a716-446655440000", limit=10
)
latest = runs.runs[0]
detail = await client.executions.get_run(latest.id)  # latest.id is the record's id, not run_id
print(detail.status, detail.output_summary)

const { runs } = await client.workflowRuns.list({
  workflowId: "550e8400-e29b-41d4-a716-446655440000",
  limit: 10,
});
const detail = await client.workflowRuns.get(runs[0].id); // runs[0].id is the record's id, not run_id
console.log(detail.status, detail.output_summary);