`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()[来源]¶

在异步上下文中运行触发器。

触发器应在想要触发事件时产生一个事件，并在完成时返回 None。因此，单事件触发器应该产生然后立即返回。

如果它产生，则很可能会很快恢复，但可能不会（例如，如果工作负载正在被移动到另一个触发器进程，或者多事件触发器被用于单事件任务延迟）。

在任何一种情况下，触发器类都应假设它们将被持久化，然后依赖于在不再需要它们时调用 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)[来源]¶

基类: airflow.triggers.base.BaseTrigger

该触发器等待 Airflow CLI 命令的结果。

serialize()[来源]¶

返回重建此触发器所需的信息。

返回: (类路径，重新实例化所需的关键字参数) 的元组。
返回类型: tuple[str, dict[str, Any]]

async run()[来源]¶

在异步上下文中运行触发器。

触发器应在想要触发事件时产生一个事件，并在完成时返回 None。因此，单事件触发器应该产生然后立即返回。

如果它产生，则很可能会很快恢复，但可能不会（例如，如果工作负载正在被移动到另一个触发器进程，或者多事件触发器被用于单事件任务延迟）。

在任何一种情况下，触发器类都应假设它们将被持久化，然后依赖于在不再需要它们时调用 cleanup()。

class airflow.providers.google.cloud.triggers.cloud_composer.CloudComposerDAGRunTrigger(project_id, region, environment_id, composer_dag_id, start_date, end_date, allowed_states, gcp_conn_id='google_cloud_default', impersonation_chain=None, poll_interval=10)[来源]¶

基类: airflow.triggers.base.BaseTrigger

该触发器等待 DAG 运行完成。

serialize()[来源]¶

返回重建此触发器所需的信息。

返回: (类路径，重新实例化所需的关键字参数) 的元组。
返回类型: tuple[str, dict[str, Any]]

async run()[来源]¶

在异步上下文中运行触发器。

触发器应在想要触发事件时产生一个事件，并在完成时返回 None。因此，单事件触发器应该产生然后立即返回。

如果它产生，则很可能会很快恢复，但可能不会（例如，如果工作负载正在被移动到另一个触发器进程，或者多事件触发器被用于单事件任务延迟）。

在任何一种情况下，触发器类都应假设它们将被持久化，然后依赖于在不再需要它们时调用 cleanup()。

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

模块内容¶

类¶

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