curl -X POST "https://api.danubeai.com/v1/workflows" \
  -H "danube-api-key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Weather Alert Pipeline",
    "description": "Get weather forecast and send Slack notification",
    "steps": [
      {
        "step_number": 1,
        "tool_id": "tool_weather_001",
        "tool_name": "Weather - Get Forecast",
        "description": "Fetch the weather forecast",
        "input_mapping": {"city": "{{inputs.city}}"}
      },
      {
        "step_number": 2,
        "tool_id": "tool_slack_001",
        "tool_name": "Slack - Send Message",
        "description": "Post forecast to Slack",
        "input_mapping": {
          "channel": "{{inputs.channel}}",
          "text": "Forecast: {{steps.1.result.forecast}}"
        }
      }
    ],
    "visibility": "private",
    "tags": ["weather", "notifications"]
  }'

from danube import DanubeClient

with DanubeClient(api_key="dk_...") as client:
    workflow = client.workflows.create(
        name="Weather Alert Pipeline",
        description="Get weather and send Slack notification",
        steps=[
            {
                "step_number": 1,
                "tool_id": "tool_weather_001",
                "tool_name": "Weather - Get Forecast",
                "description": "Fetch the weather forecast",
                "input_mapping": {"city": "{{inputs.city}}"},
            },
            {
                "step_number": 2,
                "tool_id": "tool_slack_001",
                "tool_name": "Slack - Send Message",
                "description": "Post forecast to Slack",
                "input_mapping": {
                    "channel": "{{inputs.channel}}",
                    "text": "Forecast: {{steps.1.result.forecast}}",
                },
            },
        ],
        visibility="private",
        tags=["weather", "notifications"],
    )
    print(f"Created: {workflow.id}")

import { DanubeClient } from 'danube';

const client = new DanubeClient({ apiKey: 'dk_...' });
const workflow = await client.workflows.create({
  name: 'Weather Alert Pipeline',
  description: 'Get weather and send Slack notification',
  steps: [
    {
      stepNumber: 1,
      toolId: 'tool_weather_001',
      toolName: 'Weather - Get Forecast',
      description: 'Fetch the weather forecast',
      inputMapping: { city: '{{inputs.city}}' },
    },
    {
      stepNumber: 2,
      toolId: 'tool_slack_001',
      toolName: 'Slack - Send Message',
      description: 'Post forecast to Slack',
      inputMapping: {
        channel: '{{inputs.channel}}',
        text: 'Forecast: {{steps.1.result.forecast}}',
      },
    },
  ],
  visibility: 'private',
  tags: ['weather', 'notifications'],
});
console.log(`Created: ${workflow.id}`);