`airflow.providers.google.cloud.triggers.cloud_composer`¶

模組內容¶

類別¶

`CloudComposerExecutionTrigger`	此觸發器處理與 Google Cloud Composer 的非同步溝通。
`CloudComposerAirflowCLICommandTrigger`	此觸發器等待 Airflow CLI 命令結果。
`CloudComposerDAGRunTrigger`	此觸發器等待 DAG 運行完成。

class airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerExecutionTrigger(project_id, region, operation_name, gcp_conn_id='google_cloud_default', impersonation_chain=None, pooling_period_seconds=30)[原始碼]¶

基底類別: airflow.triggers.base.BaseTrigger

此觸發器處理與 Google Cloud Composer 的非同步溝通。

serialize()[原始碼]¶

傳回重建此觸發器所需的資訊。

返回: 包含 (類別路徑, 重建所需的關鍵字參數) 的元組。
返回類型: tuple[str, dict[str, Any]]

async run()[原始碼]¶

在非同步上下文中運行觸發器。

每當觸發器想要觸發事件時，應產生一個事件 (Event)，如果完成則返回 None。單一事件觸發器應因此產生然後立即返回。

如果它產生 (yields)，則很可能很快就會恢復，但也可能不會 (例如，如果工作負載正被移動到另一個觸發器程序，或者多事件觸發器正被用於單一事件任務延遲)。

在任何情況下，觸發器類別都應假設它們將被持久化，然後依賴於在不再需要它們時調用 cleanup()。

class airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerAirflowCLICommandTrigger(project_id, region, environment_id, execution_cmd_info, gcp_conn_id='google_cloud_default', impersonation_chain=None, poll_interval=10)[原始碼]¶