airflow.providers.standard.operators.trigger_dagrun

模組內容

類別

TriggerDagRunLink

TriggerDagRunOperator 的 Operator 連結。

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 的 Operator 連結。

允許使用者使用 TriggerDagRunOperator 存取由任務觸發的 DAG。

name = '已觸發 DAG'[source]

連結至外部系統。

注意：此函數的舊簽名為 (self, operator, dttm: datetime)。在執行時仍支援，但已棄用。

參數
返回

外部系統連結

返回類型

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 (可使用 Jinja 範本)。

  • trigger_run_id (str | None) – 用於觸發的 DAG 執行的執行 ID (可使用 Jinja 範本)。如果未提供，將自動產生執行 ID。

  • conf (dict | None) – DAG 執行的組態 (可使用 Jinja 範本)。

  • logical_date (str | datetime.datetime | None) – 觸發的 DAG 的邏輯日期 (可使用 Jinja 範本)。

  • 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) – 設定為 true 以在相同邏輯日期的觸發 DAG 的 DAG 執行已存在時，將任務標記為 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]

在建立 operator 時衍生。

Context 是與呈現 Jinja 範本時使用的字典相同。

請參閱 get_template_context 以取得更多上下文。

execute_complete(context, session, event)[source]

這個條目是否有幫助？