Orchestrator

Graph

Node Configuration

Run with Parameters

Pipeline JSON

{
  "edges": [
    {
      "to": "enumerate",
      "from": "__start__"
    },
    {
      "to": "validate",
      "from": "enumerate"
    },
    {
      "to": "summary",
      "from": "validate"
    },
    {
      "from": "summary",
      "mapping": {
        "fail": "__end__",
        "pass": "cloudwatch"
      },
      "condition": "has_failures",
      "condition_config": {
        "value": 0,
        "operator": "len_gt",
        "target_path": "failed_jobs"
      }
    },
    {
      "to": "alert",
      "from": "cloudwatch"
    },
    {
      "to": "__end__",
      "from": "alert"
    }
  ],
  "nodes": [
    {
      "name": "enumerate",
      "type": "enumerate",
      "config": {
        "params": {
          "page_size": 250,
          "hours_back": 24,
          "sample_size": 2,
          "eo_max_results": 100
        },
        "function": "payload_contract_auditor",
        "response_key": "payloads"
      }
    },
    {
      "name": "validate",
      "type": "payload_contract_fan_out",
      "config": {
        "source_key": "payloads",
        "concurrency_limit": 8
      }
    },
    {
      "name": "summary",
      "type": "batch_summary",
      "config": {
        "notify_on_failure_rate": 0.0001
      }
    },
    {
      "name": "cloudwatch",
      "type": "cloudwatch_log_search",
      "config": {
        "max_failures": 5,
        "lookback_minutes": 120,
        "max_events_per_failure": 10
      }
    },
    {
      "name": "alert",
      "type": "notify",
      "config": {
        "on": "always",
        "channel": "sns",
        "subject_prefix": "[PayloadContractAuditor]"
      }
    }
  ]
}