Orchestrator

Graph

Node Configuration

Run with Parameters

Pipeline JSON

{
  "edges": [
    {
      "to": "enumerate",
      "from": "__start__"
    },
    {
      "to": "publish_kinesis",
      "from": "enumerate"
    },
    {
      "to": "__end__",
      "from": "publish_kinesis"
    }
  ],
  "nodes": [
    {
      "name": "enumerate",
      "type": "enumerate",
      "config": {
        "params": {
          "hours_back": 24
        },
        "function": "case_history_document_events",
        "response_key": "payloads",
        "timeout_seconds": 600
      }
    },
    {
      "name": "publish_kinesis",
      "type": "publish_kinesis",
      "config": {
        "source": "bdms",
        "source_key": "payloads"
      }
    }
  ]
}