airflow.providers.google.common.hooks.operation_helpers

此模組包含一個輔助類,用於處理 google.api_core.operation.Operation 物件。

OperationHelper

輔助類,用於處理 operation.Operation 物件。

模組內容

class airflow.providers.google.common.hooks.operation_helpers.OperationHelper[source]

輔助類,用於處理 operation.Operation 物件。

static wait_for_operation_result(operation, timeout=None, polling=None, retry=None)[source]

等待檢索長時間執行的操作結果。

有關高階用法,請查閱以下文件: google.api_core.future.polling.PollingFuture google.api_core.retry.Retry

引數:
  • operation (google.api_core.operation.Operation) – 用於獲取結果的初始操作。

  • timeout (int | None) – 等待操作完成的時間(以秒為單位)。如果為 None,則無限期等待。如果同時指定了 timeout 和 polling.timeout,此引數會覆蓋 polling.timeout。

  • polling (google.api_core.retry.Retry | None) – 定期呼叫輪詢 RPC 的頻率和持續時間。

  • retry (google.api_core.retry.Retry | None) – 如果發生錯誤,如何重試操作輪詢。

wait_for_operation(operation, timeout=None)[source]

遺留方法名稱包裝器。

旨在用於現有 hooks/operators,直到提供適當的棄用和替換。

此條目有幫助嗎?