Orchestrator

Graph

Node Configuration

Run with Parameters

Pipeline JSON

{
  "edges": [
    {
      "to": "enumerate",
      "from": "__start__"
    },
    {
      "to": "dispatch",
      "from": "enumerate"
    },
    {
      "to": "wait",
      "from": "dispatch"
    },
    {
      "to": "mark_seen",
      "from": "wait"
    },
    {
      "to": "summary",
      "from": "wait"
    },
    {
      "to": "__end__",
      "from": "mark_seen"
    },
    {
      "to": "alert",
      "from": "summary"
    },
    {
      "to": "__end__",
      "from": "alert"
    }
  ],
  "nodes": [
    {
      "name": "enumerate",
      "type": "enumerate",
      "config": {
        "params": {
          "tracker": "fcpa",
          "entry_filter": "indictment"
        },
        "function": "monitor_dockets",
        "response_key": "payloads"
      }
    },
    {
      "name": "dispatch",
      "type": "http_dispatch",
      "config": {
        "source_key": "payloads",
        "enrichment_key": "blaw-fcpa-indictment",
        "ace_environment": "sb",
        "skip_seen_before": true
      }
    },
    {
      "name": "wait",
      "type": "batch_await",
      "config": {
        "timeout_minutes": 45,
        "poll_interval_seconds": 5
      }
    },
    {
      "name": "mark_seen",
      "type": "enumerate",
      "config": {
        "params": {
          "tracker": "fcpa",
          "completed_jobs": "$state.completed_jobs"
        },
        "function": "blaw_mark_entries_seen_batch",
        "response_key": "mark_seen_result"
      }
    },
    {
      "name": "summary",
      "type": "batch_summary",
      "config": {
        "notify_on_failure_rate": 0.1
      }
    },
    {
      "name": "alert",
      "type": "notify",
      "config": {
        "on": "alert",
        "channel": "sns"
      }
    }
  ],
  "_comment": "Monitor FCPA candidate dockets for indictment lifecycle entries. ACE classifies each candidate and, on a positive classification, must add metadata.docket_entity_id to the fcpa-indicted watchlist through /execute/blaw_watch_docket before the ACE job completes. skip_seen_before prevents completed candidates from being redispatched; mark_seen records positive and negative classifications once ACE completes."
}