How to skip task in Airflow operator?
Figured it out! Skipping task is as easy as:
def execute():
if condition:
raise AirflowSkipException
task = PythonOperator(task_id='task', python_callable=execute, dag=some_dag)
Figured it out! Skipping task is as easy as:
def execute():
if condition:
raise AirflowSkipException
task = PythonOperator(task_id='task', python_callable=execute, dag=some_dag)