The python-storage client uses the timeout mechanics of the underlyingrequests HTTP library. The connect timeout is the number of secondsto establish a connection to the server. The read timeout is the numberof seconds the client will wait for the server to send a response.In most cases, this is the maximum wait time before the server sendsthe first byte. Please refer to therequests documentation for details.

You may also choose to configure explicit timeouts in your code, using one of three forms:

• You can specify a single value for the timeout. The timeout value will beapplied to both the connect and the read timeouts. E.g.:

bucket = client.get_bucket(BUCKET_NAME, timeout=300.0)  # five minutes

• You can also pass a two-tuple,(connect_timeout, read_timeout),if you would like to set the values separately. E.g.:

bucket = client.get_bucket(BUCKET_NAME, timeout=(3, 10))

• You can also passNone as the timeout value: in this case, the librarywill block indefinitely for a response. E.g.:

bucket = client.get_bucket(BUCKET_NAME, timeout=None)

NOTE: Depending on the retry strategy, a request may berepeated several times using the same timeout each time.

See also:

Timeouts in requests

Configuring Retries

NOTE: For more background on retries, see also theGCS Retry Strategies Document

Methods which invoke API methods may fail for a number of reasons, some ofwhich represent “transient” conditions, and thus can be retriedautomatically. The library tries to provide a sensible default retry policyfor each method, base on its semantics:

• For API requests which are always idempotent, the library uses itsDEFAULT_RETRY policy, whichretries any API request which returns a “transient” error.

• For API requests which are idempotent only if the blob hasthe same “generation”, the library uses itsDEFAULT_RETRY_IF_GENERATION_SPECIFIEDpolicy, which retries API requests which returns a “transient” error,but only if the original request includes ageneration orifGenerationMatch header.

• For API requests which are idempotent only if the bucket or blob hasthe same “metageneration”, the library uses itsDEFAULT_RETRY_IF_METAGENERATION_SPECIFIEDpolicy, which retries API requests which returns a “transient” error,but only if the original request includes anifMetagenerationMatch header.

• For API requests which are idempotent only if the bucket or blob hasthe same “etag”, the library uses itsDEFAULT_RETRY_IF_ETAG_IN_JSONpolicy, which retries API requests which returns a “transient” error,but only if the original request includes anETAG in its payload.

• For those API requests which are never idempotent, the library passesretry=None by default, suppressing any retries.

Rather than using one of the default policies, you may choose to configure anexplicit policy in your code.

• You can passNone as a retry policy to disable retries. E.g.:

bucket = client.get_bucket(BUCKET_NAME, retry=None)

• You can modify the default retry behavior and create a copy ofDEFAULT_RETRYby calling it with awith_XXX method. E.g.:

from google.cloud.storage.retry import DEFAULT_RETRY# Customize retry with a deadline of 500 seconds (default=120 seconds).modified_retry = DEFAULT_RETRY.with_deadline(500.0)# Customize retry with an initial wait time of 1.5 (default=1.0).# Customize retry with a wait time multiplier per iteration of 1.2 (default=2.0).# Customize retry with a maximum wait time of 45.0 (default=60.0).modified_retry = modified_retry.with_delay(initial=1.5, multiplier=1.2, maximum=45.0)

• You can pass an instance ofgoogle.api_core.retry.Retry to enableretries; the passed object will define retriable response codes and errors,as well as configuring backoff and retry interval options. E.g.:

from google.api_core import exceptionsfrom google.api_core.retry import Retry_MY_RETRIABLE_TYPES = [   exceptions.TooManyRequests,  # 429   exceptions.InternalServerError,  # 500   exceptions.BadGateway,  # 502   exceptions.ServiceUnavailable,  # 503]def is_retryable(exc):    return isinstance(exc, _MY_RETRIABLE_TYPES)my_retry_policy = Retry(predicate=is_retryable)bucket = client.get_bucket(BUCKET_NAME, retry=my_retry_policy)

• You can pass an instance ofgoogle.cloud.storage.retry.ConditionalRetryPolicy, which wraps aRetryPolicy, activating it only ifcertain conditions are met. This class exists to provide safe defaultsfor RPC calls that are not technically safe to retry normally (due topotential data duplication or other side-effects) but become safe to retryif a condition such as if_metageneration_match is set. E.g.:

from google.api_core.retry import Retryfrom google.cloud.storage.retry import ConditionalRetryPolicyfrom google.cloud.storage.retry importis_etag_in_datadef is_retryable(exc):    ... # as abovemy_retry_policy = Retry(predicate=is_retryable)my_cond_policy = ConditionalRetryPolicy(    my_retry_policy, conditional_predicate=is_etag_in_data, ["query_params"])bucket = client.get_bucket(BUCKET_NAME, retry=my_cond_policy)