airflow.example_dags.example_skip_dag¶

Example DAG demonstrating the EmptyOperator and a custom EmptySkipOperator which skips by default.

Classes¶

Empty operator which always skips the task.

Instantiate a number of operators for the given DAG.

class airflow.example_dags.example_skip_dag.EmptySkipOperator(**kwargs)[source]¶

Bases: airflow.models.baseoperator.BaseOperator

Empty operator which always skips the task.

execute(context)[source]¶

Derive when creating an operator.

Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

airflow.example_dags.example_skip_dag.create_test_pipeline(suffix, trigger_rule)[source]¶

Instantiate a number of operators for the given DAG.

Parameters: