Page MenuHomePhabricator

Refactor analytics_test/dags/custom_operators_tryout_dag.py
Open, Needs TriagePublic

Description

analytics_test should only contain jobs that are active and executed regularly on the test cluster. It's currently not the case for custom_operators_tryout_dag

We can change this DAG so that its dag_runs succeed when all sensors and operators behave as expected.

We could use Airflow's trigger rules to succeed only when the previous task fails. This way we can leave it running in the test cluster.

It would be awesome if we make it send alerts only if there's something unexpected.