diff --git a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/async_client.py b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/async_client.py index b8fc974a..9a91feae 100644 --- a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/async_client.py +++ b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/async_client.py @@ -199,7 +199,7 @@ async def create_read_session( number of pre-filtered rows, so some filters can lead to lopsided assignments. - Read sessions automatically expire 24 hours after they + Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller. diff --git a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/client.py b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/client.py index f1838685..35675b84 100644 --- a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/client.py +++ b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/client.py @@ -420,7 +420,7 @@ def create_read_session( number of pre-filtered rows, so some filters can lead to lopsided assignments. - Read sessions automatically expire 24 hours after they + Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller. diff --git a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc.py b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc.py index 54f5fed1..42f4e733 100644 --- a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc.py +++ b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc.py @@ -255,7 +255,7 @@ def create_read_session( number of pre-filtered rows, so some filters can lead to lopsided assignments. - Read sessions automatically expire 24 hours after they + Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller. diff --git a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc_asyncio.py b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc_asyncio.py index 7cb0784f..2b7433a3 100644 --- a/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc_asyncio.py +++ b/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc_asyncio.py @@ -258,7 +258,7 @@ def create_read_session( number of pre-filtered rows, so some filters can lead to lopsided assignments. - Read sessions automatically expire 24 hours after they + Read sessions automatically expire 6 hours after they are created and do not require manual clean-up by the caller. diff --git a/google/cloud/bigquery_storage_v1beta2/services/big_query_write/async_client.py b/google/cloud/bigquery_storage_v1beta2/services/big_query_write/async_client.py index 497182fb..9c6ba354 100644 --- a/google/cloud/bigquery_storage_v1beta2/services/big_query_write/async_client.py +++ b/google/cloud/bigquery_storage_v1beta2/services/big_query_write/async_client.py @@ -331,9 +331,9 @@ def append_rows( core_exceptions.ResourceExhausted, core_exceptions.ServiceUnavailable, ), - deadline=None, + deadline=86400.0, ), - default_timeout=None, + default_timeout=86400.0, client_info=DEFAULT_CLIENT_INFO, ) diff --git a/google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/base.py b/google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/base.py index 7286ce5b..78571ced 100644 --- a/google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/base.py +++ b/google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/base.py @@ -185,9 +185,9 @@ def _prep_wrapped_messages(self, client_info): core_exceptions.ResourceExhausted, core_exceptions.ServiceUnavailable, ), - deadline=None, + deadline=86400.0, ), - default_timeout=None, + default_timeout=86400.0, client_info=client_info, ), self.get_write_stream: gapic_v1.method.wrap_method(