HTTP

Execute HTTP requests to web services and APIs.

Basic Usage

steps:
  - name: get-data
    type: http
    command: GET https://jsonplaceholder.typicode.com/todos/1

Configuration

Field	Description	Example
headers	Request headers	Authorization: Bearer token
query	URL parameters	page: "1"
body	Request body	{"name": "value"}
timeout	Timeout in seconds	30
silent	Return body only (suppress status/headers on success)	true
debug	Enable debug mode (logs request/response details)	true
json	Format output as structured JSON	true
skipTLSVerify	Skip TLS certificate verification	true

Examples

POST with JSON

steps:
  - name: create-resource
    type: http
    config:
      body: '{"name": "New Resource"}'
      headers:
        Content-Type: application/json
    command: POST https://api.example.com/resources

Authentication

steps:
  - name: bearer-auth
    type: http
    config:
      headers:
        Authorization: "Bearer ${API_TOKEN}"
    command: GET https://api.example.com/protected

Query Parameters

steps:
  - name: search
    type: http
    config:
      query:
        q: "search term"
        limit: "10"
    command: GET https://api.example.com/search

Capture Response

steps:
  - name: get-user
    type: http
    config:
      silent: true
    command: GET https://api.example.com/user
    output: USER_DATA

  - name: process
    command: echo "${USER_DATA}" | jq '.email'

JSON Output Mode

Use json: true to get structured JSON output including status code and headers:

steps:
  - name: api-call
    type: http
    config:
      json: true
      silent: true
    command: GET https://api.example.com/data
    output: RESPONSE

Output format:

{
  "status_code": 200,
  "headers": {
    "Content-Type": "application/json"
  },
  "body": {"key": "value"}
}

Error Handling

steps:
  - name: api-call
    type: http
    config:
      timeout: 30
    command: GET https://api.example.com/data
    retryPolicy:
      limit: 3
      intervalSec: 5
    continueOn:
      exitCode: [1]  # Non-2xx status codes

Webhook Notification

handlerOn:
  success:
    type: http
    config:
      body: '{"status": "completed", "dag": "${DAG_NAME}"}'
      headers:
        Content-Type: application/json
    command: POST https://hooks.example.com/workflow-complete

Self-Signed Certificates

steps:
  - name: internal-api
    type: http
    config:
      skipTLSVerify: true  # Allow self-signed certificates
      headers:
        Authorization: "Bearer ${INTERNAL_TOKEN}"
    command: GET https://internal-api.company.local/data