Creating a custom Operator — Airflow 3.1.0 Documentation