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)[source]¶

基类: 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')[source]¶

success_states[source]¶

failure_states[source]¶

workflow_id[source]¶

execution_id[source]¶

location[source]¶

project_id = None[source]¶

retry[source]¶

request_timeout = None[source]¶

metadata = ()[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

impersonation_chain = None[source]¶

poke(context)[source]¶

派生此类时重写。