Create and start pipeline
create_pipelineCreate AND start a multi-step pipeline (e.g. scrap → emails → verify_emails). Chains are linear: each block feeds the next. Edges use the keys "from" and "to" (not source/target). Valid block types and config fields are described by get_pipeline_schema. Returns pipeline id + initial job ids. Example definition: {"nodes": [{"id": "n1", "type": "scrap", "config": {"queries": ["plombier"], "zones": ["Lyon"], "stop_at": 500}}, {"id": "n2", "type": "emails", "config": {}}], "edges": [{"id": "e1", "from": "n1", "to": "n2"}]}
Tool call template
Replace each placeholder with a value matching the input schema. Only required parameters are included; add optional parameters as needed.
{
"id": 1,
"jsonrpc": "2.0",
"method": "tools/call",
"params": {
"arguments": {
"definition": "<definition>"
},
"name": "create_pipeline"
}
}Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| name | No | ||
| definition | Yes | {nodes: [{id, type, config}], edges: [{id, from, to}]} — edge keys are "from"/"to", not source/target | |
| low_priority | No | The pipeline's jobs run after other jobs in the queue. A low-priority pipeline costs less. |