d3p_pipeline_execute
Execute a multi-service pipeline by chaining d3p services with automatic schema mapping and atomic payments, using step definitions and a budget cap.
Instructions
Execute a multi-service pipeline — chain d3p services together with automatic schema mapping and atomic payments. Parameters (JSON string): steps (list, required): pipeline step definitions, each with: service_id (str): which service to call input_mapping (dict): map from $pipeline_input or $steps.N.output pipeline_input (dict): initial input data max_total_sats (int): budget cap timeout_seconds (int): overall timeout Example: {"pipeline_input": {"query": "bitcoin news"}, "steps": [ {"service_id": "search", "input_mapping": {"query": "$pipeline_input.query"}}, {"service_id": "sentiment", "input_mapping": {"text": "$steps.0.output.answer"}} ]}
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| pipeline | No | {} |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |