airflow.models.skipmixin

Module Contents

class airflow.models.skipmixin.SkipMixin[source]

Bases:airflow.utils.log.logging_mixin.LoggingMixin

skip(self, dag_run, execution_date, tasks, session=None)[source]

Sets tasks instances to skipped from the same dag run.

Parameters

  • dag_run – the DagRun for which to set the tasks to skipped

  • execution_date – execution_date

  • tasks – tasks to skip (not task_ids)

  • session – db session to use