chore: change default retry policies timeouts (#53)

Author: plamut

packages/google-cloud-bigquery-storage/docs/conf.py

@@ -29,7 +29,7 @@
 # -- General configuration ------------------------------------------------
 
 # If your documentation needs a minimal Sphinx version, state it here.
-needs_sphinx = "1.6.3"
+needs_sphinx = "1.5.5"
 
 # Add any Sphinx extension module names here, as strings. They can be
 # extensions coming with Sphinx (named 'sphinx.ext.*') or your custom

packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/gapic/big_query_read_client.py

@@ -273,8 +273,9 @@ def create_read_session(
             >>> response = client.create_read_session(parent, read_session)
 
         Args:
-            parent (str): Required. The request project that owns the session, in the form of
-                ``projects/{project_id}``.
+            parent (str): The resource has one pattern, but the API owner expects to add more
+                later. (This is the inverse of ORIGINALLY_SINGLE_PATTERN, and prevents
+                that from being necessary once there are multiple patterns.)
             read_session (Union[dict, ~google.cloud.bigquery_storage_v1.types.ReadSession]): Required. Session to be created.
 
                 If a dict is provided, it must be of the same form as the protobuf
@@ -427,18 +428,13 @@ def split_read_stream(
         metadata=None,
     ):
         """
-        Splits a given ``ReadStream`` into two ``ReadStream`` objects. These
-        ``ReadStream`` objects are referred to as the primary and the residual
-        streams of the split. The original ``ReadStream`` can still be read from
-        in the same manner as before. Both of the returned ``ReadStream``
-        objects can also be read from, and the rows returned by both child
-        streams will be the same as the rows read from the original stream.
-
-        Moreover, the two child streams will be allocated back-to-back in the
-        original ``ReadStream``. Concretely, it is guaranteed that for streams
-        original, primary, and residual, that original[0-j] = primary[0-j] and
-        original[j-n] = residual[0-m] once the streams have been read to
-        completion.
+        An indicator of the behavior of a given field (for example, that a
+        field is required in requests, or given as output but ignored as input).
+        This **does not** change the behavior in protocol buffers itself; it
+        only denotes the behavior and may affect how API tooling handles the
+        field.
+
+        Note: This enum **may** receive new values in the future.
 
         Example:
             >>> from google.cloud import bigquery_storage_v1

packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/gapic/big_query_read_client_config.py

@@ -2,54 +2,64 @@
     "interfaces": {
         "google.cloud.bigquery.storage.v1.BigQueryRead": {
             "retry_codes": {
-                "idempotent": ["DEADLINE_EXCEEDED", "UNAVAILABLE"],
-                "unary_streaming": ["UNAVAILABLE"],
-                "non_idempotent": [],
+                "retry_policy_1_codes": ["DEADLINE_EXCEEDED", "UNAVAILABLE"],
+                "no_retry_codes": [],
+                "retry_policy_3_codes": ["DEADLINE_EXCEEDED", "UNAVAILABLE"],
+                "retry_policy_2_codes": ["UNAVAILABLE"],
             },
             "retry_params": {
-                "default": {
+                "retry_policy_1_params": {
                     "initial_retry_delay_millis": 100,
                     "retry_delay_multiplier": 1.3,
                     "max_retry_delay_millis": 60000,
-                    "initial_rpc_timeout_millis": 20000,
+                    "initial_rpc_timeout_millis": 600000,
                     "rpc_timeout_multiplier": 1.0,
-                    "max_rpc_timeout_millis": 20000,
+                    "max_rpc_timeout_millis": 600000,
                     "total_timeout_millis": 600000,
                 },
-                "create_read_session": {
+                "retry_policy_2_params": {
                     "initial_retry_delay_millis": 100,
                     "retry_delay_multiplier": 1.3,
                     "max_retry_delay_millis": 60000,
-                    "initial_rpc_timeout_millis": 120000,
+                    "initial_rpc_timeout_millis": 86400000,
                     "rpc_timeout_multiplier": 1.0,
-                    "max_rpc_timeout_millis": 120000,
-                    "total_timeout_millis": 600000,
+                    "max_rpc_timeout_millis": 86400000,
+                    "total_timeout_millis": 86400000,
                 },
-                "read_rows": {
+                "retry_policy_3_params": {
                     "initial_retry_delay_millis": 100,
                     "retry_delay_multiplier": 1.3,
                     "max_retry_delay_millis": 60000,
-                    "initial_rpc_timeout_millis": 86400000,
+                    "initial_rpc_timeout_millis": 600000,
                     "rpc_timeout_multiplier": 1.0,
-                    "max_rpc_timeout_millis": 86400000,
-                    "total_timeout_millis": 86400000,
+                    "max_rpc_timeout_millis": 600000,
+                    "total_timeout_millis": 600000,
+                },
+                "no_retry_params": {
+                    "initial_retry_delay_millis": 0,
+                    "retry_delay_multiplier": 0.0,
+                    "max_retry_delay_millis": 0,
+                    "initial_rpc_timeout_millis": 0,
+                    "rpc_timeout_multiplier": 1.0,
+                    "max_rpc_timeout_millis": 0,
+                    "total_timeout_millis": 0,
                 },
             },
             "methods": {
                 "CreateReadSession": {
                     "timeout_millis": 120000,
-                    "retry_codes_name": "idempotent",
-                    "retry_params_name": "create_read_session",
+                    "retry_codes_name": "retry_policy_1_codes",
+                    "retry_params_name": "retry_policy_1_params",
                 },
                 "ReadRows": {
                     "timeout_millis": 21600000,
-                    "retry_codes_name": "unary_streaming",
-                    "retry_params_name": "read_rows",
+                    "retry_codes_name": "retry_policy_2_codes",
+                    "retry_params_name": "retry_policy_2_params",
                 },
                 "SplitReadStream": {
                     "timeout_millis": 120000,
-                    "retry_codes_name": "idempotent",
-                    "retry_params_name": "default",
+                    "retry_codes_name": "retry_policy_3_codes",
+                    "retry_params_name": "retry_policy_3_params",
                 },
             },
         }

packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/gapic/transports/big_query_read_grpc_transport.py

@@ -168,18 +168,13 @@ def read_rows(self):
     def split_read_stream(self):
         """Return the gRPC stub for :meth:`BigQueryReadClient.split_read_stream`.
 
-        Splits a given ``ReadStream`` into two ``ReadStream`` objects. These
-        ``ReadStream`` objects are referred to as the primary and the residual
-        streams of the split. The original ``ReadStream`` can still be read from
-        in the same manner as before. Both of the returned ``ReadStream``
-        objects can also be read from, and the rows returned by both child
-        streams will be the same as the rows read from the original stream.
-
-        Moreover, the two child streams will be allocated back-to-back in the
-        original ``ReadStream``. Concretely, it is guaranteed that for streams
-        original, primary, and residual, that original[0-j] = primary[0-j] and
-        original[j-n] = residual[0-m] once the streams have been read to
-        completion.
+        An indicator of the behavior of a given field (for example, that a
+        field is required in requests, or given as output but ignored as input).
+        This **does not** change the behavior in protocol buffers itself; it
+        only denotes the behavior and may affect how API tooling handles the
+        field.
+
+        Note: This enum **may** receive new values in the future.
 
         Returns:
             Callable: A callable which accepts the appropriate

packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/proto/arrow_pb2.py

@@ -1,2 +1,3 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
 import grpc

packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/proto/arrow_pb2_grpc.py

@@ -1,2 +1,3 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
 import grpc