This is an automated email from the ASF dual-hosted git repository.
phanikumv pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new b1e506b1a7 fix(providers/google): add missing sync_hook_class to
CloudDataTransferServiceAsyncHook (#41417)
b1e506b1a7 is described below
commit b1e506b1a7dd49ecdbefe0463a05e3dbbcb02f31
Author: Wei Lee <[email protected]>
AuthorDate: Tue Aug 13 15:38:44 2024 +0800
fix(providers/google): add missing sync_hook_class to
CloudDataTransferServiceAsyncHook (#41417)
---
airflow/providers/google/cloud/hooks/cloud_storage_transfer_service.py | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/airflow/providers/google/cloud/hooks/cloud_storage_transfer_service.py
b/airflow/providers/google/cloud/hooks/cloud_storage_transfer_service.py
index 9c994e9d72..607090ff6a 100644
--- a/airflow/providers/google/cloud/hooks/cloud_storage_transfer_service.py
+++ b/airflow/providers/google/cloud/hooks/cloud_storage_transfer_service.py
@@ -552,6 +552,8 @@ class CloudDataTransferServiceHook(GoogleBaseHook):
class CloudDataTransferServiceAsyncHook(GoogleBaseAsyncHook):
"""Asynchronous hook for Google Storage Transfer Service."""
+ sync_hook_class = CloudDataTransferServiceHook
+
def __init__(self, project_id: str = PROVIDE_PROJECT_ID, **kwargs: Any) ->
None:
super().__init__(**kwargs)
self.project_id = project_id
