Бэкенд agentic-воркфлоу для многошаговых AI-агентов

{
  "schemaVersion": 1,
  "nodes": [
    { "id": "in",      "kind": "httpTrigger", "name": "Start research", "config": { "method": "POST" } },
    { "id": "search",  "kind": "lambda", "name": "Search docs",
      "config": { "functionId": "search-docs",
                  "inputMapping": { "query": "{{trigger.body.query}}" },
                  "retryPolicy": { "maxAttempts": 3, "backoffMs": 1000, "strategy": "exponential" } } },
    { "id": "draft",   "kind": "lambda", "name": "Generate draft",
      "config": { "functionId": "generate-draft",
                  "inputMapping": { "results": "{{steps.search.output.results}}" } } },
    { "id": "approve", "kind": "humanGate", "name": "Approve publish",
      "config": { "mode": "approve", "promptTemplate": "Publish the draft for {{trigger.body.query}}?" } },
    { "id": "publish", "kind": "lambda", "name": "Publish result", "config": { "functionId": "publish-result" } },
    { "id": "reject",  "kind": "lambda", "name": "Notify rejected", "config": { "functionId": "notify-rejected" } }
  ],
  "edges": [
    { "id": "e1", "sourceNodeId": "in",      "targetNodeId": "search" },
    { "id": "e2", "sourceNodeId": "search",  "targetNodeId": "draft",   "sourceHandle": "success" },
    { "id": "e3", "sourceNodeId": "draft",   "targetNodeId": "approve", "sourceHandle": "success" },
    { "id": "e4", "sourceNodeId": "approve", "targetNodeId": "publish", "sourceHandle": "approve" },
    { "id": "e5", "sourceNodeId": "approve", "targetNodeId": "reject",  "sourceHandle": "reject" }
  ]
}

export async function handler(event) {
  // API key auth enforced at the gateway route before this code runs
  const { query } = JSON.parse(event.body || '{}');
  const results = await searchInternalDocs(query); // DB_URL from workspace secrets
  return { statusCode: 200, body: JSON.stringify({ results, count: results.length }) };
}

# The httpTrigger node exposes the pipeline on a gateway route.
# POST a query to start a run; it flows search -> draft -> approval.
curl -X POST https://<your-app>/api/research-agent \
  -H "X-Api-Key: $INQUIR_API_KEY" \
  -d '{"query":"Q3 pricing changes"}'
# -> { "runId": "...", "status": "RUNNING" }
# The run pauses at the humanGate until someone approves or rejects;
# each step's input, output, and retry count is in the execution history.