airflow.example_dags.example_skip_dag

示例 DAG 演示了 EmptyOperator 和一个默认跳过的自定义 EmptySkipOperator。

模块内容

类

EmptySkipOperator

始终跳过任务的空操作符。

函数

create_test_pipeline(suffix, trigger_rule)

实例化给定 DAG 的多个操作符。
class airflow.example_dags.example_skip_dag.EmptySkipOperator(task_id, owner=DEFAULT_OWNER, email=None, email_on_retry=conf.getboolean('email', 'default_email_on_retry', fallback=True), email_on_failure=conf.getboolean('email', 'default_email_on_failure', fallback=True), retries=DEFAULT_RETRIES, retry_delay=DEFAULT_RETRY_DELAY, retry_exponential_backoff=False, max_retry_delay=None, start_date=None, end_date=None, depends_on_past=False, ignore_first_depends_on_past=DEFAULT_IGNORE_FIRST_DEPENDS_ON_PAST, wait_for_past_depends_before_skipping=DEFAULT_WAIT_FOR_PAST_DEPENDS_BEFORE_SKIPPING, wait_for_downstream=False, dag=None, params=None, default_args=None, priority_weight=DEFAULT_PRIORITY_WEIGHT, weight_rule=DEFAULT_WEIGHT_RULE, queue=DEFAULT_QUEUE, pool=None, pool_slots=DEFAULT_POOL_SLOTS, sla=None, execution_timeout=DEFAULT_TASK_EXECUTION_TIMEOUT, on_execute_callback=None, on_failure_callback=None, on_success_callback=None, on_retry_callback=None, on_skipped_callback=None, pre_execute=None, post_execute=None, trigger_rule=DEFAULT_TRIGGER_RULE, resources=None, run_as_user=None, task_concurrency=None, map_index_template=None, max_active_tis_per_dag=None, max_active_tis_per_dagrun=None, executor=None, executor_config=None, do_xcom_push=True, multiple_outputs=False, inlets=None, outlets=None, task_group=None, doc=None, doc_md=None, doc_json=None, doc_yaml=None, doc_rst=None, task_display_name=None, logger_name=None, allow_nested_operators=True, **kwargs)[source]

基类: airflow.models.baseoperator.BaseOperator

始终跳过任务的空操作符。

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 的多个操作符。

参数

  • suffix (str) – 要附加到 operator task_ids 的后缀

  • trigger_rule (str) – join 任务的 TriggerRule

  • dag (DAG) – 要在其上运行 operator 的 DAG

此条目是否有帮助？