airflow.example_dags.example_skip_dag
演示 EmptyOperator 和默认跳过的自定义 EmptySkipOperator 的示例 DAG。
模块内容
-
class airflow.example_dags.example_skip_dag.EmptySkipOperator(**kwargs)[source]
基类: airflow.models.baseoperator.BaseOperator
总是跳过任务的空 Operator。
-
ui_color = '#e8b7e4'[source]
-
execute(context)[source]
创建 Operator 时派生。
Context 是与渲染 jinja 模板时使用的相同的字典。
请参阅 get_template_context 获取更多上下文信息。
-
airflow.example_dags.example_skip_dag.create_test_pipeline(suffix, trigger_rule)[source]
为给定的 DAG 实例化多个 Operator。
- 参数：
suffix (str) – 要添加到 Operator task_ids 的后缀
trigger_rule (str) – 用于 join 任务的 TriggerRule
dag (DAG) – 运行 Operator 的 DAG