airflow.providers.standard.operators.trigger_dagrun

模块内容

类

TriggerDagRunLink

用于 TriggerDagRunOperator 的操作符链接。

TriggerDagRunOperator

为指定的 DAG ID 触发 DAG 运行。

属性

XCOM_LOGICAL_DATE_ISO

XCOM_RUN_ID

airflow.providers.standard.operators.trigger_dagrun.XCOM_LOGICAL_DATE_ISO = 'trigger_logical_date_iso'[source]
airflow.providers.standard.operators.trigger_dagrun.XCOM_RUN_ID = 'trigger_run_id'[source]

基类: airflow.models.BaseOperatorLink

用于 TriggerDagRunOperator 的操作符链接。

它允许用户访问使用 TriggerDagRunOperator 触发的 DAG。

name = '触发的 DAG'[source]

链接到外部系统。

注意：此函数的旧签名是 (self, operator, dttm: datetime)。这在运行时仍然受支持，但已弃用。

参数

  • operator (airflow.models.BaseOperator) – 此链接关联的 Airflow 操作符对象。

  • ti_key (airflow.models.taskinstancekey.TaskInstanceKey) – 要为其返回链接的 TaskInstance ID。

返回

外部系统的链接

返回类型

str

class airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator(*, trigger_dag_id, trigger_run_id=None, conf=None, logical_date=None, reset_dag_run=False, wait_for_completion=False, poke_interval=60, allowed_states=None, failed_states=None, skip_when_already_exists=False, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]

基类: airflow.models.BaseOperator

为指定的 DAG ID 触发 DAG 运行。

请注意，如果启用了数据库隔离模式，则并非所有功能都受支持。

参数

  • trigger_dag_id (str) – 要触发的 DAG 的 dag_id (已模板化)。

  • trigger_run_id (str | None) – 用于触发的 DAG 运行的运行 ID (已模板化)。如果未提供，将自动生成运行 ID。

  • conf (dict | None) – DAG 运行的配置 (已模板化)。

  • logical_date (str | datetime.datetime | None) – 触发的 DAG 的逻辑日期 (已模板化)。

  • reset_dag_run (bool) – 是否在已存在的情况下清除现有 DAG 运行。这在回填或重新运行现有 DAG 运行时很有用。这只会重置(而不是重新创建) DAG 运行。DAG 运行配置是不可变的，并且不会在重新运行现有 DAG 运行时重置。当 reset_dag_run=False 且 DAG 运行存在时，将引发 DagRunAlreadyExists。当 reset_dag_run=True 且 DAG 运行存在时，将清除现有 DAG 运行以重新运行。

  • wait_for_completion (bool) – 是否等待 DAG 运行完成。(默认值：False)

  • poke_interval (int) – 当 wait_for_completion=True 时，检查 DAG 运行状态的轮询间隔。(默认值：60)

  • allowed_states (list[str | airflow.utils.state.DagRunState] | None) – 触发的 DAG 的允许 DAG 运行状态的可选列表。这在将 wait_for_completion 设置为 True 时很有用。必须是有效的 DagRunState。默认值为 [DagRunState.SUCCESS]。

  • failed_states (list[str | airflow.utils.state.DagRunState] | None) – 触发的 DAG 的失败或不允许的 DAG 运行状态的可选列表。这在将 wait_for_completion 设置为 True 时很有用。必须是有效的 DagRunState。默认值为 [DagRunState.FAILED]。

  • skip_when_already_exists (bool) – 如果同一逻辑日期的触发 DAG 的 DAG 运行已存在，则设置为 true 以将任务标记为 SKIPPED。

  • deferrable (bool) – 如果等待完成，是否将任务延迟到完成，默认值为 False。

template_fields: collections.abc.Sequence[str] = ('trigger_dag_id', 'trigger_run_id', 'logical_date', 'conf', 'wait_for_completion',...[source]
template_fields_renderers[source]
ui_color = '#ffefeb'[source]
execute(context)[source]

在创建操作符时派生。

上下文是与渲染 Jinja 模板时使用的相同字典。

有关更多上下文，请参阅 get_template_context。

execute_complete(context, session, event)[source]

此条目是否有帮助？