Basic Tasks

# Example: Content analysis agent
id: analyze-content
$use: agent(local::agents.#(id=="content-analyst"))
action: analyze_content

agent:
  id: content-analyst
  config:
    provider: anthropic
    model: claude-3-5-haiku-latest
  instructions: |
    Analyze the provided content for:
    1. Key themes and topics
    2. Sentiment and tone
    3. Target audience
    4. Content quality score (1-10)

    Return structured JSON with your analysis.
  actions:
    - id: analyze_content
      json_mode: true
      output:
        type: object
        properties:
          themes: { type: array, items: { type: string } }
          sentiment: { type: string, enum: ["positive", "negative", "neutral"] }
          tone: { type: string }
          audience: { type: string }
          quality_score: { type: number, minimum: 1, maximum: 10 }
        required: [themes, sentiment, tone, audience, quality_score]

with:
  content: "{{ .workflow.input.text }}"
  metadata: "{{ .workflow.input.context }}"

# Example: Data processing tool
id: process-csv
$use: tool(local::tools.#(id=="csv-processor"))

tool:
  id: csv-processor
  description: Process CSV data with filtering and transformation
  input:
    type: object
    properties:
      csv_data: { type: string }
      filters: { type: object }
      transformations: { type: array }
    required: [csv_data]

with:
  csv_data: "{{ .workflow.input.raw_data }}"
  filters:
    status: "active"
    date_range: "{{ .workflow.input.date_filter }}"
  transformations:
    - type: "normalize_names"
    - type: "calculate_totals"

outputs:
  processed_data: "{{ .output.data }}"
  row_count: "{{ .output.count }}"
  processing_time: "{{ .output.duration }}"

with:
  # Simple value substitution
  user_id: "{{ .workflow.input.user_id }}"

  # Complex expressions with functions
  timestamp: "{{ now | date '2006-01-02 15:04:05' }}"

  # Conditional values
  priority: "{{ .workflow.input.priority | default 'medium' }}"

  # Nested object construction
  metadata:
    source: "{{ .workflow.id }}"
    user: "{{ .workflow.input.user_id }}"
    environment: "{{ .env.ENVIRONMENT }}"
    created_at: "{{ now }}"

  # Array manipulation
  tags: "{{ .workflow.input.tags | append 'processed' }}"

  # Mathematical operations
  score: "{{ mul .workflow.input.base_score 1.2 }}"

outputs:
  # Direct field mapping
  result: "{{ .output.data }}"

  # Computed values
  summary: "Processed {{ .output.count }} items in {{ .task.duration }}"

  # Complex object creation
  metadata:
    task_id: "{{ .task.id }}"
    execution_time: "{{ .task.duration }}"
    input_size: "{{ len .with.data }}"
    success: "{{ not .task.error }}"

  # Conditional outputs
  status: "{{ if .output.errors }}failed{{ else }}success{{ end }}"

  # Type conversions
  count_string: "{{ .output.count | toString }}"
  score_number: "{{ .output.score | toNumber }}"

# Efficient task configuration
id: optimized-task
$use: tool(local::tools.#(id=="processor"))

# Set appropriate timeouts
timeout: 2m
heartbeat_timeout: 30s

# Optimize retry strategy
retry_policy:
  maximum_attempts: 2
  initial_interval: 1s
  maximum_interval: 10s

# Minimal input/output
with:
  # Only pass necessary data
  id: "{{ .workflow.input.item_id }}"
  action: "process"

outputs:
  # Only extract needed fields
  result: "{{ .output.status }}"
  id: "{{ .output.id }}"

id: resilient-task
$use: agent(local::agents.#(id=="processor"))
action: process

# Comprehensive error handling
retry_policy:
  maximum_attempts: 3
  initial_interval: 1s
  maximum_interval: 1m
  backoff_coefficient: 2.0
  non_retryable_error_types:
    - "ValidationError"
    - "AuthenticationError"

on_error:
  next: error-recovery
  with:
    error_context:
      original_input: "{{ .task.with }}"
      error_type: "{{ .task.error.type }}"
      error_message: "{{ .task.error.message }}"
      retry_count: "{{ .task.retry_count }}"
      task_id: "{{ .task.id }}"

# Timeout protection
schedule_to_close_timeout: 10m
start_to_close_timeout: 5m