airflow.providers.google.common.hooks.operation_helpers¶
此模組包含一個輔助類,用於處理 google.api_core.operation.Operation 物件。
類¶
輔助類,用於處理 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.PollingFuturegoogle.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) – 如果發生錯誤,如何重試操作輪詢。