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

模块内容¶

类¶

`RunJobStatus`	用于表示作业运行状态的枚举。
`CloudRunJobFinishedTrigger`	用于检查模板作业是否已完成的 Cloud Run 触发器。

属性¶

DEFAULT_BATCH_LOCATION

airflow.providers.google.cloud.triggers.cloud_run.DEFAULT_BATCH_LOCATION = 'us-central1'[源代码]¶

class airflow.providers.google.cloud.triggers.cloud_run.RunJobStatus[源代码]¶

基类： enum.Enum

用于表示作业运行状态的枚举。

SUCCESS = 'Success'[源代码]¶

FAIL = 'Fail'[源代码]¶

TIMEOUT = 'Timeout'[源代码]¶

class airflow.providers.google.cloud.triggers.cloud_run.CloudRunJobFinishedTrigger(operation_name, job_name, project_id, location=DEFAULT_BATCH_LOCATION, gcp_conn_id='google_cloud_default', impersonation_chain=None, polling_period_seconds=10, timeout=None)[源代码]¶

基类： airflow.triggers.base.BaseTrigger

用于检查模板作业是否已完成的 Cloud Run 触发器。

参数

operation_name (str) – 必需。操作的名称。
job_name (str) – 必需。作业的名称。
project_id (str | None) – 必需。启动作业的 Google Cloud 项目 ID。
location (str) – 可选。作业执行的地点。如果设置为 None，则将使用 DEFAULT_BATCH_LOCATION 的值。
gcp_conn_id (str) – 用于连接 Google Cloud 的连接 ID。
impersonation_chain (str | collections.abc.Sequence[str] | None) – 可选。使用短期凭证模拟的服务帐户，或获取列表中最后一个帐户的 access_token 所需的链接帐户列表，该帐户将在请求中被模拟。如果设置为字符串，则该帐户必须授予发起帐户“服务帐户令牌创建者”IAM 角色。如果设置为序列，则列表中的标识必须将“服务帐户令牌创建者”IAM 角色授予紧邻其前的标识，列表中的第一个帐户将此角色授予发起帐户（已模板化）。
poll_sleep – 用于检查状态的轮询周期（以秒为单位）。

超时

在操作失败之前等待的时间。

serialize()[源代码]¶

序列化类参数和类路径。

async run()[源代码]¶

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

触发器应在其要触发事件时生成一个事件，如果已完成，则返回 None。因此，单事件触发器应生成事件然后立即返回。

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

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

airflow.providers.google.cloud.triggers.cloud_run¶

模块内容¶

类¶

属性¶

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