airflow.providers.standard.operators.trigger_dagrun

屬性

XCOM_LOGICAL_DATE_ISO

XCOM_RUN_ID

類

TriggerDagRunLink

TriggerDagRunOperator 的 Operator 連結。

TriggerDagRunOperator

為指定的 DAG ID 觸發一個 DAG 執行。

模組內容

airflow.providers.standard.operators.trigger_dagrun.XCOM_LOGICAL_DATE_ISO = 'trigger_logical_date_iso'[原始碼]
airflow.providers.standard.operators.trigger_dagrun.XCOM_RUN_ID = 'trigger_run_id'[原始碼]

基類: airflow.sdk.BaseOperatorLink

TriggerDagRunOperator 的 Operator 連結。

它允許使用者訪問由 TriggerDagRunOperator 觸發的 DAG。

name = '觸發的 DAG'[原始碼]

連結的名稱。這將是任務 UI 上的按鈕名稱。

外部系統的連結。

引數::
返回::

外部系統的連結

返回型別::

str

class airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator(*, trigger_dag_id, trigger_run_id=None, conf=None, logical_date=NOTSET, 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)[原始碼]

基類: airflow.models.BaseOperator

為指定的 DAG ID 觸發一個 DAG 執行。

請注意，如果啟用了資料庫隔離模式，則並非所有功能都受支援。

引數::

  • trigger_dag_id (str) – 要觸發的 DAG 的 dag_id（模板化）。

  • trigger_run_id (str | None) – 用於觸發的 DAG 執行的 run ID（模板化）。如果未提供，將自動生成 run ID。

  • conf (dict | None) – DAG 執行的配置（模板化）。

  • logical_date (str | datetime.datetime | None | airflow.utils.types.ArgNotSet) – 觸發的 DAG 的邏輯日期（模板化）。

  • reset_dag_run (bool) – 是否清除已存在的 DAG 執行。這在回填或重新執行現有 DAG 執行時很有用。這隻會重置（而不是重新建立）DAG 執行。DAG 執行 conf 是不可變的，在重新執行現有 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 執行允許的狀態列表（可選）。這在設定 wait_for_completion 為 True 時很有用。必須是有效的 DagRunState。預設值是 [DagRunState.SUCCESS]。

  • failed_states (list[str | airflow.utils.state.DagRunState] | None) – 觸發的 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',...[原始碼]
template_fields_renderers[原始碼]
ui_color = '#ffefeb'[原始碼]
trigger_dag_id[原始碼]
trigger_run_id = None[原始碼]
conf = None[原始碼]
reset_dag_run = False[原始碼]
wait_for_completion = False[原始碼]
poke_interval = 60[原始碼]
skip_when_already_exists = False[原始碼]
logical_date[原始碼]
execute(context)[原始碼]

建立 operator 時派生。

上下文是與渲染 jinja 模板時使用的字典相同。

有關更多上下文，請參閱 get_template_context。

execute_complete(context, event)[原始碼]

此條目是否有幫助？