Orchestrator

le_relevancy_weekly_report

Version: 20260608164700-2fff0508

Graph

run_report (http_request)
email_report (http_request)

Node Configuration

run_report (http_request)
KeyValue
path
method
headers_env
X-API-Key
max_retries
base_url_env
timeout_seconds
response_extract
report_id
expected_status_codes
email_report (http_request)
KeyValue
body
to
subject
report_id
path
method
headers_env
X-API-Key
max_retries
base_url_env
timeout_seconds
response_extract
email_job_id
expected_status_codes
Saves to disk and updates any active crons using this pipeline

Run with Parameters

Pipeline JSON

{
  "edges": [
    {
      "to": "run_report",
      "from": "__start__"
    },
    {
      "from": "run_report",
      "mapping": {
        "fail": "__end__",
        "pass": "email_report"
      },
      "condition": "output_check",
      "condition_config": {
        "conditions": [
          {
            "value": null,
            "operator": "neq",
            "target_path": "metadata.report_id"
          }
        ]
      }
    },
    {
      "to": "__end__",
      "from": "email_report"
    }
  ],
  "nodes": [
    {
      "name": "run_report",
      "type": "http_request",
      "config": {
        "path": "/reports/le-relevancy-weekly/run",
        "method": "POST",
        "headers_env": {
          "X-API-Key": "ACE_PLATFORM_API_KEY"
        },
        "max_retries": 1,
        "base_url_env": "ACE_PLATFORM_URL",
        "timeout_seconds": 300,
        "response_extract": {
          "report_id": "result.report_id"
        },
        "expected_status_codes": [
          200
        ]
      }
    },
    {
      "name": "email_report",
      "type": "http_request",
      "config": {
        "body": {
          "to": "$runtime.to",
          "subject": "$runtime.subject",
          "report_id": "$state.metadata.report_id"
        },
        "path": "/reports/le-relevancy-weekly/email",
        "method": "POST",
        "headers_env": {
          "X-API-Key": "ACE_PLATFORM_API_KEY"
        },
        "max_retries": 1,
        "base_url_env": "ACE_PLATFORM_URL",
        "timeout_seconds": 30,
        "response_extract": {
          "email_job_id": "email_job_id"
        },
        "expected_status_codes": [
          202
        ]
      }
    }
  ],
  "description": "L&E Relevancy Weekly Report \u2014 run and conditionally email",
  "runtime_params": [
    {
      "name": "to",
      "default": null,
      "description": "Recipient email addresses as a JSON array, e.g. [\"user@example.com\"]"
    },
    {
      "name": "subject",
      "default": null,
      "description": "Optional email subject override (uses report default when omitted)"
    }
  ]
}
Back to Pipelines