공부
[Airflow] How to skip task in Airflow operator?
승가비
2023. 4. 26. 22:52
728x90
def execute():
if condition:
raise AirflowSkipException
task = PythonOperator(task_id='task', python_callable=execute, dag=some_dag)https://stackoverflow.com/questions/58414350/how-to-skip-task-in-airflow-operator
How to skip task in Airflow operator?
Is there a way for Airflow to skip current task from the PythonOperator? For example: def execute(): if condition: skip_current_task() task = PythonOperator(task_id='task', python_call...
stackoverflow.com
https://towardsdatascience.com/airflow-skip-task-a5a6ab319378
How to Skip Tasks in Airflow DAGs
Skipping tasks in Airflow DAGs based on specific conditions
towardsdatascience.com
728x90