Creating a custom Operator — Airflow Documentation