Creating a custom Operator — Airflow Documentation
airflow.apache.org