chore: upgrade gapic-generator-python to 0.43.2

google/cloud/tasks_v2/services/cloud_tasks/async_client.py

@@ -36,7 +36,7 @@
 from google.cloud.tasks_v2.types import task
 from google.cloud.tasks_v2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import duration_pb2 as duration  # type: ignore
 from google.protobuf import field_mask_pb2 as field_mask  # type: ignore
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
@@ -922,7 +922,7 @@ async def get_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Gets the access control policy for a
         [Queue][google.cloud.tasks.v2.Queue]. Returns an empty policy if
         the resource exists and does not have a policy set.
@@ -1067,7 +1067,7 @@ async def set_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Sets the access control policy for a
         [Queue][google.cloud.tasks.v2.Queue]. Replaces any existing
         policy.

google/cloud/tasks_v2/services/cloud_tasks/client.py

@@ -40,7 +40,7 @@
 from google.cloud.tasks_v2.types import task
 from google.cloud.tasks_v2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import duration_pb2 as duration  # type: ignore
 from google.protobuf import field_mask_pb2 as field_mask  # type: ignore
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
@@ -1095,7 +1095,7 @@ def get_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Gets the access control policy for a
         [Queue][google.cloud.tasks.v2.Queue]. Returns an empty policy if
         the resource exists and does not have a policy set.
@@ -1230,7 +1230,7 @@ def set_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Sets the access control policy for a
         [Queue][google.cloud.tasks.v2.Queue]. Replaces any existing
         policy.

google/cloud/tasks_v2/services/cloud_tasks/transports/base.py

@@ -31,7 +31,7 @@
 from google.cloud.tasks_v2.types import task
 from google.cloud.tasks_v2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import empty_pb2 as empty  # type: ignore
 
 
@@ -329,7 +329,7 @@ def get_iam_policy(
         self,
     ) -> typing.Callable[
         [iam_policy.GetIamPolicyRequest],
-        typing.Union[policy.Policy, typing.Awaitable[policy.Policy]],
+        typing.Union[giv_policy.Policy, typing.Awaitable[giv_policy.Policy]],
     ]:
         raise NotImplementedError()
 
@@ -338,7 +338,7 @@ def set_iam_policy(
         self,
     ) -> typing.Callable[
         [iam_policy.SetIamPolicyRequest],
-        typing.Union[policy.Policy, typing.Awaitable[policy.Policy]],
+        typing.Union[giv_policy.Policy, typing.Awaitable[giv_policy.Policy]],
     ]:
         raise NotImplementedError()
 

google/cloud/tasks_v2/services/cloud_tasks/transports/grpc.py

@@ -32,7 +32,7 @@
 from google.cloud.tasks_v2.types import task
 from google.cloud.tasks_v2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import empty_pb2 as empty  # type: ignore
 
 from .base import CloudTasksTransport, DEFAULT_CLIENT_INFO
@@ -491,7 +491,7 @@ def resume_queue(self) -> Callable[[cloudtasks.ResumeQueueRequest], queue.Queue]
     @property
     def get_iam_policy(
         self,
-    ) -> Callable[[iam_policy.GetIamPolicyRequest], policy.Policy]:
+    ) -> Callable[[iam_policy.GetIamPolicyRequest], giv_policy.Policy]:
         r"""Return a callable for the get iam policy method over gRPC.
 
         Gets the access control policy for a
@@ -518,14 +518,14 @@ def get_iam_policy(
             self._stubs["get_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2.CloudTasks/GetIamPolicy",
                 request_serializer=iam_policy.GetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["get_iam_policy"]
 
     @property
     def set_iam_policy(
         self,
-    ) -> Callable[[iam_policy.SetIamPolicyRequest], policy.Policy]:
+    ) -> Callable[[iam_policy.SetIamPolicyRequest], giv_policy.Policy]:
         r"""Return a callable for the set iam policy method over gRPC.
 
         Sets the access control policy for a
@@ -556,7 +556,7 @@ def set_iam_policy(
             self._stubs["set_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2.CloudTasks/SetIamPolicy",
                 request_serializer=iam_policy.SetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["set_iam_policy"]
 

google/cloud/tasks_v2/services/cloud_tasks/transports/grpc_asyncio.py

@@ -33,7 +33,7 @@
 from google.cloud.tasks_v2.types import task
 from google.cloud.tasks_v2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import empty_pb2 as empty  # type: ignore
 
 from .base import CloudTasksTransport, DEFAULT_CLIENT_INFO
@@ -507,7 +507,7 @@ def resume_queue(
     @property
     def get_iam_policy(
         self,
-    ) -> Callable[[iam_policy.GetIamPolicyRequest], Awaitable[policy.Policy]]:
+    ) -> Callable[[iam_policy.GetIamPolicyRequest], Awaitable[giv_policy.Policy]]:
         r"""Return a callable for the get iam policy method over gRPC.
 
         Gets the access control policy for a
@@ -534,14 +534,14 @@ def get_iam_policy(
             self._stubs["get_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2.CloudTasks/GetIamPolicy",
                 request_serializer=iam_policy.GetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["get_iam_policy"]
 
     @property
     def set_iam_policy(
         self,
-    ) -> Callable[[iam_policy.SetIamPolicyRequest], Awaitable[policy.Policy]]:
+    ) -> Callable[[iam_policy.SetIamPolicyRequest], Awaitable[giv_policy.Policy]]:
         r"""Return a callable for the set iam policy method over gRPC.
 
         Sets the access control policy for a
@@ -572,7 +572,7 @@ def set_iam_policy(
             self._stubs["set_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2.CloudTasks/SetIamPolicy",
                 request_serializer=iam_policy.SetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["set_iam_policy"]
 

google/cloud/tasks_v2beta2/services/cloud_tasks/async_client.py

@@ -36,7 +36,7 @@
 from google.cloud.tasks_v2beta2.types import task
 from google.cloud.tasks_v2beta2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import duration_pb2 as duration  # type: ignore
 from google.protobuf import field_mask_pb2 as field_mask  # type: ignore
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
@@ -923,7 +923,7 @@ async def get_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Gets the access control policy for a
         [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty
         policy if the resource exists and does not have a policy set.
@@ -1068,7 +1068,7 @@ async def set_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Sets the access control policy for a
         [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
         policy.

google/cloud/tasks_v2beta2/services/cloud_tasks/client.py

@@ -40,7 +40,7 @@
 from google.cloud.tasks_v2beta2.types import task
 from google.cloud.tasks_v2beta2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import duration_pb2 as duration  # type: ignore
 from google.protobuf import field_mask_pb2 as field_mask  # type: ignore
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
@@ -1096,7 +1096,7 @@ def get_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Gets the access control policy for a
         [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty
         policy if the resource exists and does not have a policy set.
@@ -1231,7 +1231,7 @@ def set_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Sets the access control policy for a
         [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
         policy.

google/cloud/tasks_v2beta2/services/cloud_tasks/transports/base.py

@@ -31,7 +31,7 @@
 from google.cloud.tasks_v2beta2.types import task
 from google.cloud.tasks_v2beta2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import empty_pb2 as empty  # type: ignore
 
 
@@ -341,7 +341,7 @@ def get_iam_policy(
         self,
     ) -> typing.Callable[
         [iam_policy.GetIamPolicyRequest],
-        typing.Union[policy.Policy, typing.Awaitable[policy.Policy]],
+        typing.Union[giv_policy.Policy, typing.Awaitable[giv_policy.Policy]],
     ]:
         raise NotImplementedError()
 
@@ -350,7 +350,7 @@ def set_iam_policy(
         self,
     ) -> typing.Callable[
         [iam_policy.SetIamPolicyRequest],
-        typing.Union[policy.Policy, typing.Awaitable[policy.Policy]],
+        typing.Union[giv_policy.Policy, typing.Awaitable[giv_policy.Policy]],
     ]:
         raise NotImplementedError()
 

google/cloud/tasks_v2beta2/services/cloud_tasks/transports/grpc.py

@@ -32,7 +32,7 @@
 from google.cloud.tasks_v2beta2.types import task
 from google.cloud.tasks_v2beta2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import empty_pb2 as empty  # type: ignore
 
 from .base import CloudTasksTransport, DEFAULT_CLIENT_INFO
@@ -491,7 +491,7 @@ def resume_queue(self) -> Callable[[cloudtasks.ResumeQueueRequest], queue.Queue]
     @property
     def get_iam_policy(
         self,
-    ) -> Callable[[iam_policy.GetIamPolicyRequest], policy.Policy]:
+    ) -> Callable[[iam_policy.GetIamPolicyRequest], giv_policy.Policy]:
         r"""Return a callable for the get iam policy method over gRPC.
 
         Gets the access control policy for a
@@ -518,14 +518,14 @@ def get_iam_policy(
             self._stubs["get_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2beta2.CloudTasks/GetIamPolicy",
                 request_serializer=iam_policy.GetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["get_iam_policy"]
 
     @property
     def set_iam_policy(
         self,
-    ) -> Callable[[iam_policy.SetIamPolicyRequest], policy.Policy]:
+    ) -> Callable[[iam_policy.SetIamPolicyRequest], giv_policy.Policy]:
         r"""Return a callable for the set iam policy method over gRPC.
 
         Sets the access control policy for a
@@ -556,7 +556,7 @@ def set_iam_policy(
             self._stubs["set_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2beta2.CloudTasks/SetIamPolicy",
                 request_serializer=iam_policy.SetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["set_iam_policy"]
 

google/cloud/tasks_v2beta2/services/cloud_tasks/transports/grpc_asyncio.py

@@ -33,7 +33,7 @@
 from google.cloud.tasks_v2beta2.types import task
 from google.cloud.tasks_v2beta2.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import empty_pb2 as empty  # type: ignore
 
 from .base import CloudTasksTransport, DEFAULT_CLIENT_INFO
@@ -507,7 +507,7 @@ def resume_queue(
     @property
     def get_iam_policy(
         self,
-    ) -> Callable[[iam_policy.GetIamPolicyRequest], Awaitable[policy.Policy]]:
+    ) -> Callable[[iam_policy.GetIamPolicyRequest], Awaitable[giv_policy.Policy]]:
         r"""Return a callable for the get iam policy method over gRPC.
 
         Gets the access control policy for a
@@ -534,14 +534,14 @@ def get_iam_policy(
             self._stubs["get_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2beta2.CloudTasks/GetIamPolicy",
                 request_serializer=iam_policy.GetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["get_iam_policy"]
 
     @property
     def set_iam_policy(
         self,
-    ) -> Callable[[iam_policy.SetIamPolicyRequest], Awaitable[policy.Policy]]:
+    ) -> Callable[[iam_policy.SetIamPolicyRequest], Awaitable[giv_policy.Policy]]:
         r"""Return a callable for the set iam policy method over gRPC.
 
         Sets the access control policy for a
@@ -572,7 +572,7 @@ def set_iam_policy(
             self._stubs["set_iam_policy"] = self.grpc_channel.unary_unary(
                 "/google.cloud.tasks.v2beta2.CloudTasks/SetIamPolicy",
                 request_serializer=iam_policy.SetIamPolicyRequest.SerializeToString,
-                response_deserializer=policy.Policy.FromString,
+                response_deserializer=giv_policy.Policy.FromString,
             )
         return self._stubs["set_iam_policy"]
 

google/cloud/tasks_v2beta3/services/cloud_tasks/async_client.py

@@ -36,7 +36,7 @@
 from google.cloud.tasks_v2beta3.types import task
 from google.cloud.tasks_v2beta3.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import duration_pb2 as duration  # type: ignore
 from google.protobuf import field_mask_pb2 as field_mask  # type: ignore
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
@@ -923,7 +923,7 @@ async def get_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Gets the access control policy for a
         [Queue][google.cloud.tasks.v2beta3.Queue]. Returns an empty
         policy if the resource exists and does not have a policy set.
@@ -1068,7 +1068,7 @@ async def set_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Sets the access control policy for a
         [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing
         policy.

google/cloud/tasks_v2beta3/services/cloud_tasks/client.py

@@ -40,7 +40,7 @@
 from google.cloud.tasks_v2beta3.types import task
 from google.cloud.tasks_v2beta3.types import task as gct_task
 from google.iam.v1 import iam_policy_pb2 as iam_policy  # type: ignore
-from google.iam.v1 import policy_pb2 as policy  # type: ignore
+from google.iam.v1 import policy_pb2 as giv_policy  # type: ignore
 from google.protobuf import duration_pb2 as duration  # type: ignore
 from google.protobuf import field_mask_pb2 as field_mask  # type: ignore
 from google.protobuf import timestamp_pb2 as timestamp  # type: ignore
@@ -1096,7 +1096,7 @@ def get_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Gets the access control policy for a
         [Queue][google.cloud.tasks.v2beta3.Queue]. Returns an empty
         policy if the resource exists and does not have a policy set.
@@ -1231,7 +1231,7 @@ def set_iam_policy(
         retry: retries.Retry = gapic_v1.method.DEFAULT,
         timeout: float = None,
         metadata: Sequence[Tuple[str, str]] = (),
-    ) -> policy.Policy:
+    ) -> giv_policy.Policy:
         r"""Sets the access control policy for a
         [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing
         policy.