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]¶

派生此類時重寫。