Tool node

{
  "id": "create_issue_1",
  "type": "tool",
  "name": "Open GitHub issue",
  "x": 720,
  "y": 160,
  "retry_config": {
    "max_attempts": 3,
    "initial_interval": 1.0,
    "backoff_factor": 2.0,
    "retry_on_error_types": ["TimeoutError", "ConnectionError", "HTTPError"]
  },
  "tool_config": {
    "tool": {
      "integration_name": "github",
      "service_name": "create_issue",
      "credential_id": "cred_gh_7a1c",
      "parameter_overrides": {
        "owner": "octocat",
        "repo": "hello-world"
      }
    },
    "input_mapping": {
      "title": "{{triage_1.summary}}",
      "body": "Priority: {{triage_1.priority}}\n\nReported by {{intake_1.reporter}}.",
      "labels": ["triage", "{{triage_1.priority}}"]
    }
  }
}

# 1. Start the run (POST /workflows/run). Returns run metadata immediately.
curl https://api.modulex.dev/workflows/run \
  -H "Authorization: Bearer mx_live_xxxxxxxxxxxxxxxxxxxx" \
  -H "X-Organization-ID: org_4d2b18" \
  -H "Content-Type: application/json" \
  -d '{
        "workflow_id": "wf_7f3a9c",
        "input": {
          "intake_1": { "reporter": "alex", "message": "Invoice double-charged me." }
        }
      }'
# -> { "status": "running", "run_id": "run_8b21", "thread_id": "thr_44", ... }

# 2. Stream events (SSE). Each frame is `data: <json>`; switch on the `type` field.
#    The created issue arrives on the create_issue_1 node_update event.
curl -N https://api.modulex.dev/workflows/listen/run_8b21 \
  -H "Authorization: Bearer mx_live_xxxxxxxxxxxxxxxxxxxx" \
  -H "X-Organization-ID: org_4d2b18"

import asyncio
from modulex import Modulex


async def main():
    async with Modulex(
        api_key="mx_live_xxxxxxxxxxxxxxxxxxxx",
        organization_id="org_4d2b18",
    ) as client:
        # 1. Start the run (returns immediately with run metadata).
        run = await client.executions.run(
            workflow_id="wf_7f3a9c",
            input={
                "intake_1": {"reporter": "alex", "message": "Invoice double-charged me."},
            },
        )

        # 2. Stream events; the created issue arrives on create_issue_1's node_update.
        async for event in client.executions.listen(run.run_id):
            if event.event == "node_update" and event.data.get("node") == "create_issue_1":
                output = event.data["output"]["create_issue_1"]
                print(output["issue"]["number"])  # -> 42
                print(output["issue"]["url"])


asyncio.run(main())

import { Modulex } from "modulex-js";

const client = new Modulex({
  apiKey: "mx_live_xxxxxxxxxxxxxxxxxxxx",
  organizationId: "org_4d2b18",
});

// 1. Start the run (returns immediately with run metadata).
const run = await client.executions.run({
  workflowId: "wf_7f3a9c",
  input: {
    intake_1: { reporter: "alex", message: "Invoice double-charged me." },
  },
});

// 2. Stream events; the created issue arrives on create_issue_1's node_update.
for await (const event of client.executions.listen(run.run_id)) {
  if (event.type === "node_update" && event.node === "create_issue_1") {
    const output = event.output.create_issue_1;
    console.log(output.issue.number); // -> 42
    console.log(output.issue.url);
  }
}