`airflow.providers.google.cloud.sensors.workflows`¶

模块内容¶

类¶

WorkflowExecutionSensor

检查给定 workflow_id 和 execution_id 的执行状态。

class airflow.providers.google.cloud.sensors.workflows.WorkflowExecutionSensor(*, workflow_id, execution_id, location, project_id=PROVIDE_PROJECT_ID, success_states=None, failure_states=None, retry=DEFAULT, request_timeout=None, metadata=(), gcp_conn_id='google_cloud_default', impersonation_chain=None, **kwargs)[源代码]¶

基类：airflow.sensors.base.BaseSensorOperator

检查给定 workflow_id 和 execution_id 的执行状态。

参数

workflow_id (str) – 必需。工作流的 ID。
execution_id (str) – 必需。执行的 ID。
project_id (str) – 必需。集群所属的 Google Cloud 项目的 ID。
location (str) – 必需。处理请求的 Cloud Dataproc 区域。
success_states (set[google.cloud.workflows.executions_v1beta.Execution.State] | None) – 要被视为成功的执行状态，默认情况下只有 SUCCEEDED 状态
failure_states (set[google.cloud.workflows.executions_v1beta.Execution.State] | None) – 要被视为失败的执行状态，默认情况下为 FAILED 和 CANCELLED 状态。
retry (google.api_core.retry.Retry | google.api_core.gapic_v1.method._MethodDefault) – 用于重试请求的重试对象。如果指定 None，则不会重试请求。
request_timeout (float | None) – 等待请求完成的时间量（以秒为单位）。请注意，如果指定了 retry，则超时适用于每次单独的尝试。
metadata (collections.abc.Sequence[tuple[str, str]]) – 提供给方法的其他元数据。

template_fields: collections.abc.Sequence[str] = ('location', 'workflow_id', 'execution_id')[源代码]¶

poke(context)[源代码]¶

当派生此类时重写。

airflow.providers.google.cloud.sensors.workflows¶

模块内容¶

类¶

`airflow.providers.google.cloud.sensors.workflows`¶