Implement custom status-tracking Airflow operator