chore: Use gapic-generator-python 0.65.0 (#158)

- [ ] Regenerate this pull request now. PiperOrigin-RevId: 440970084 Source-Link: googleapis/googleapis@5e0a3d5 Source-Link: googleapis/googleapis-gen@b0c628a Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjBjNjI4YTNmYWRlNzY4ZjIyNWQ3Njk5Mjc5MWVhMWJhMmE4ODFiZSJ9 docs: fix type in docstring for map fields
googleapis · Apr 12, 2022 · f3ec9da · f3ec9da
1 parent 51c3fbc
commit f3ec9da
Show file tree

Hide file tree

Showing 22 changed files with 294 additions and 110 deletions.
diff --git a/google/cloud/workflows/executions_v1/services/executions/async_client.py b/google/cloud/workflows/executions_v1/services/executions/async_client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -216,7 +216,6 @@ async def list_executions(
         executions are ordered by their start time (newest
         first).
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1
@@ -331,7 +330,6 @@ async def create_execution(
         r"""Creates a new execution using the latest revision of
         the given workflow.
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1

diff --git a/google/cloud/workflows/executions_v1/services/executions/client.py b/google/cloud/workflows/executions_v1/services/executions/client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -466,7 +466,6 @@ def list_executions(
         executions are ordered by their start time (newest
         first).
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1
@@ -581,7 +580,6 @@ def create_execution(
         r"""Creates a new execution using the latest revision of
         the given workflow.
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1

diff --git a/google/cloud/workflows/executions_v1/services/executions/transports/base.py b/google/cloud/workflows/executions_v1/services/executions/transports/base.py
@@ -80,6 +80,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -190,5 +191,9 @@ def cancel_execution(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("ExecutionsTransport",)
diff --git a/google/cloud/workflows/executions_v1/services/executions/transports/grpc.py b/google/cloud/workflows/executions_v1/services/executions/transports/grpc.py
@@ -342,5 +342,9 @@ def cancel_execution(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("ExecutionsGrpcTransport",)
diff --git a/google/cloud/workflows/executions_v1beta/services/executions/async_client.py b/google/cloud/workflows/executions_v1beta/services/executions/async_client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -217,7 +217,6 @@ async def list_executions(
         executions are ordered by their start time (newest
         first).
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1beta
@@ -332,7 +331,6 @@ async def create_execution(
         r"""Creates a new execution using the latest revision of
         the given workflow.
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1beta

diff --git a/google/cloud/workflows/executions_v1beta/services/executions/client.py b/google/cloud/workflows/executions_v1beta/services/executions/client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -467,7 +467,6 @@ def list_executions(
         executions are ordered by their start time (newest
         first).
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1beta
@@ -582,7 +581,6 @@ def create_execution(
         r"""Creates a new execution using the latest revision of
         the given workflow.
 
-
         .. code-block:: python
 
             from google.cloud.workflows import executions_v1beta

diff --git a/google/cloud/workflows/executions_v1beta/services/executions/transports/base.py b/google/cloud/workflows/executions_v1beta/services/executions/transports/base.py
@@ -80,6 +80,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -190,5 +191,9 @@ def cancel_execution(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("ExecutionsTransport",)
diff --git a/google/cloud/workflows/executions_v1beta/services/executions/transports/grpc.py b/google/cloud/workflows/executions_v1beta/services/executions/transports/grpc.py
@@ -343,5 +343,9 @@ def cancel_execution(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("ExecutionsGrpcTransport",)
diff --git a/google/cloud/workflows_v1/services/workflows/async_client.py b/google/cloud/workflows_v1/services/workflows/async_client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -216,7 +216,6 @@ async def list_workflows(
         r"""Lists Workflows in a given project and location.
         The default order is not specified.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1
@@ -431,7 +430,6 @@ async def create_workflow(
         running operation will return
         [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1
@@ -576,7 +574,6 @@ async def delete_workflow(
         This method also cancels and deletes all running
         executions of the workflow.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1
@@ -705,7 +702,6 @@ async def update_workflow(
         update operation. In that case, such revision will be
         used in new workflow executions.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1

diff --git a/google/cloud/workflows_v1/services/workflows/client.py b/google/cloud/workflows_v1/services/workflows/client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -444,7 +444,6 @@ def list_workflows(
         r"""Lists Workflows in a given project and location.
         The default order is not specified.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1
@@ -659,7 +658,6 @@ def create_workflow(
         running operation will return
         [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1
@@ -804,7 +802,6 @@ def delete_workflow(
         This method also cancels and deletes all running
         executions of the workflow.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1
@@ -933,7 +930,6 @@ def update_workflow(
         update operation. In that case, such revision will be
         used in new workflow executions.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1

diff --git a/google/cloud/workflows_v1/services/workflows/transports/base.py b/google/cloud/workflows_v1/services/workflows/transports/base.py
@@ -82,6 +82,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -210,5 +211,9 @@ def update_workflow(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("WorkflowsTransport",)
diff --git a/google/cloud/workflows_v1/services/workflows/transports/grpc.py b/google/cloud/workflows_v1/services/workflows/transports/grpc.py
@@ -390,5 +390,9 @@ def update_workflow(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("WorkflowsGrpcTransport",)
diff --git a/google/cloud/workflows_v1/types/workflows.py b/google/cloud/workflows_v1/types/workflows.py
@@ -73,7 +73,7 @@ class Workflow(proto.Message):
         revision_create_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. The timestamp that the latest
             revision of the workflow was created.
-        labels (Sequence[google.cloud.workflows_v1.types.Workflow.LabelsEntry]):
+        labels (Mapping[str, str]):
             Labels associated with this workflow.
             Labels can contain at most 64 entries. Keys and
             values can be no longer than 63 characters and

diff --git a/google/cloud/workflows_v1beta/services/workflows/async_client.py b/google/cloud/workflows_v1beta/services/workflows/async_client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import functools
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core.client_options import ClientOptions
@@ -216,7 +216,6 @@ async def list_workflows(
         r"""Lists Workflows in a given project and location.
         The default order is not specified.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta
@@ -431,7 +430,6 @@ async def create_workflow(
         running operation will return
         [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta
@@ -576,7 +574,6 @@ async def delete_workflow(
         This method also cancels and deletes all running
         executions of the workflow.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta
@@ -705,7 +702,6 @@ async def update_workflow(
         update operation. In that case, such revision will be
         used in new workflow executions.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta

diff --git a/google/cloud/workflows_v1beta/services/workflows/client.py b/google/cloud/workflows_v1beta/services/workflows/client.py
@@ -16,7 +16,7 @@
 from collections import OrderedDict
 import os
 import re
-from typing import Dict, Optional, Sequence, Tuple, Type, Union
+from typing import Dict, Mapping, Optional, Sequence, Tuple, Type, Union
 import pkg_resources
 
 from google.api_core import client_options as client_options_lib
@@ -444,7 +444,6 @@ def list_workflows(
         r"""Lists Workflows in a given project and location.
         The default order is not specified.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta
@@ -659,7 +658,6 @@ def create_workflow(
         running operation will return
         [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta
@@ -804,7 +802,6 @@ def delete_workflow(
         This method also cancels and deletes all running
         executions of the workflow.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta
@@ -933,7 +930,6 @@ def update_workflow(
         update operation. In that case, such revision will be
         used in new workflow executions.
 
-
         .. code-block:: python
 
             from google.cloud import workflows_v1beta

diff --git a/google/cloud/workflows_v1beta/services/workflows/transports/base.py b/google/cloud/workflows_v1beta/services/workflows/transports/base.py
@@ -82,6 +82,7 @@ def __init__(
             always_use_jwt_access (Optional[bool]): Whether self signed JWT should
                 be used for service account credentials.
         """
+
         # Save the hostname. Default to port 443 (HTTPS) if none is specified.
         if ":" not in host:
             host += ":443"
@@ -210,5 +211,9 @@ def update_workflow(
     ]:
         raise NotImplementedError()
 
+    @property
+    def kind(self) -> str:
+        raise NotImplementedError()
+
 
 __all__ = ("WorkflowsTransport",)
diff --git a/google/cloud/workflows_v1beta/services/workflows/transports/grpc.py b/google/cloud/workflows_v1beta/services/workflows/transports/grpc.py
@@ -390,5 +390,9 @@ def update_workflow(
     def close(self):
         self.grpc_channel.close()
 
+    @property
+    def kind(self) -> str:
+        return "grpc"
+
 
 __all__ = ("WorkflowsGrpcTransport",)
diff --git a/google/cloud/workflows_v1beta/types/workflows.py b/google/cloud/workflows_v1beta/types/workflows.py
@@ -70,7 +70,7 @@ class Workflow(proto.Message):
         revision_create_time (google.protobuf.timestamp_pb2.Timestamp):
             Output only. The timestamp that the latest
             revision of the workflow was created.
-        labels (Sequence[google.cloud.workflows_v1beta.types.Workflow.LabelsEntry]):
+        labels (Mapping[str, str]):
             Labels associated with this workflow.
             Labels can contain at most 64 entries. Keys and
             values can be no longer than 63 characters and