Migrate any legacy batch scheduler to Apache Airflow.

Control-M Automation API JSON

{
  "DAILY_ETL": {
    "Type": "Folder",
    "EXTRACT": {
      "Type": "Job:Command",
      "Command": "/etl/extract.sh",
      "eventsToAdd": {
        "Events": [{ "Event": "EXTRACT-OK" }]
      }
    },
    "LOAD": {
      "Type": "Job:Command",
      "Command": "/etl/load.sh",
      "eventsToWaitFor": {
        "Events": [{ "Event": "EXTRACT-OK" }]
      }
    }
  }
}

Apache Airflow DAG

from airflow.decorators import dag
from airflow.operators.bash import BashOperator
from pendulum import datetime

@dag(
    schedule="0 1 * * 1-5",
    start_date=datetime(2025, 1, 1),
    catchup=False,
)
def daily_etl():
    extract = BashOperator(
        task_id="extract",
        bash_command="/opt/etl/extract.sh",
    )
    load = BashOperator(
        task_id="load",
        bash_command="/opt/etl/load.sh",
    )
    extract >> load

daily_etl()