fix: update retry and timeout config (#39)

* feat: regenerate library using Bazel adds additional module name overrides sets default timeout and retry config in base * chore: corrects module name in setup.py

Author: danoscarmike

.coveragerc

@@ -28,6 +28,11 @@ exclude_lines =
  def __repr__
  # Ignore abstract methods
  raise NotImplementedError
+ # Ignore pkg_resources exceptions.
+ # This is added at the module level as a safeguard for if someone
+ # generates the code and tries to run it without pip installing. This
+ # makes it virtually impossible to test properly.
+ except pkg_resources.DistributionNotFound
 omit =
  */gapic/*.py
  */proto/*.py

docs/translate_v3/services.rst

@@ -1,5 +1,5 @@
-Services for Google Cloud Translation v3 API
-============================================
+Services for Google Cloud Translate v3 API
+==========================================
 
 .. automodule:: google.cloud.translate_v3.services.translation_service
  :members:

docs/translate_v3/types.rst

@@ -1,5 +1,5 @@
-Types for Google Cloud Translation v3 API
-=========================================
+Types for Google Cloud Translate v3 API
+=======================================
 
 .. automodule:: google.cloud.translate_v3.types
  :members:

docs/translate_v3beta1/services.rst

@@ -1,5 +1,5 @@
-Services for Google Cloud Translation v3beta1 API
-=================================================
+Services for Google Cloud Translate v3beta1 API
+===============================================
 
 .. automodule:: google.cloud.translate_v3beta1.services.translation_service
  :members:

docs/translate_v3beta1/types.rst

@@ -1,5 +1,5 @@
-Types for Google Cloud Translation v3beta1 API
-==============================================
+Types for Google Cloud Translate v3beta1 API
+============================================
 
 .. automodule:: google.cloud.translate_v3beta1.types
  :members:

google/cloud/translate/py.typed

@@ -1,2 +1,2 @@
 # Marker file for PEP 561.
-# The google-cloud-translation package uses inline types.
+# The google-cloud-translate package uses inline types.

google/cloud/translate_v3/py.typed

@@ -1,2 +1,2 @@
 # Marker file for PEP 561.
-# The google-cloud-translation package uses inline types.
+# The google-cloud-translate package uses inline types.

google/cloud/translate_v3/services/translation_service/async_client.py

@@ -247,7 +247,7 @@ async def translate_text(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.translate_text,
- default_timeout=None,
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -367,7 +367,7 @@ async def detect_language(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.detect_language,
- default_timeout=None,
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -485,7 +485,15 @@ async def get_supported_languages(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.get_supported_languages,
- default_timeout=None,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -549,7 +557,7 @@ async def batch_translate_text(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.batch_translate_text,
- default_timeout=None,
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -638,7 +646,7 @@ async def create_glossary(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.create_glossary,
- default_timeout=None,
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -720,7 +728,15 @@ async def list_glossaries(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.list_glossaries,
- default_timeout=None,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -797,7 +813,15 @@ async def get_glossary(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.get_glossary,
- default_timeout=None,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -874,7 +898,15 @@ async def delete_glossary(
  # and friendly error handling.
  rpc = gapic_v1.method_async.wrap_method(
  self._client._transport.delete_glossary,
- default_timeout=None,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
  client_info=_client_info,
  )
 
@@ -901,9 +933,7 @@ async def delete_glossary(
 
 try:
  _client_info = gapic_v1.client_info.ClientInfo(
- gapic_version=pkg_resources.get_distribution(
- "google-cloud-translation",
- ).version,
+ gapic_version=pkg_resources.get_distribution("google-cloud-translate",).version,
  )
 except pkg_resources.DistributionNotFound:
  _client_info = gapic_v1.client_info.ClientInfo()

google/cloud/translate_v3/services/translation_service/client.py

@@ -1057,9 +1057,7 @@ def delete_glossary(
 
 try:
  _client_info = gapic_v1.client_info.ClientInfo(
- gapic_version=pkg_resources.get_distribution(
- "google-cloud-translation",
- ).version,
+ gapic_version=pkg_resources.get_distribution("google-cloud-translate",).version,
  )
 except pkg_resources.DistributionNotFound:
  _client_info = gapic_v1.client_info.ClientInfo()

google/cloud/translate_v3/services/translation_service/transports/base.py

@@ -32,9 +32,7 @@
 
 try:
  _client_info = gapic_v1.client_info.ClientInfo(
- gapic_version=pkg_resources.get_distribution(
- "google-cloud-translation",
- ).version,
+ gapic_version=pkg_resources.get_distribution("google-cloud-translate",).version,
  )
 except pkg_resources.DistributionNotFound:
  _client_info = gapic_v1.client_info.ClientInfo()
@@ -106,32 +104,70 @@ def _prep_wrapped_messages(self):
  # Precompute the wrapped methods.
  self._wrapped_methods = {
  self.translate_text: gapic_v1.method.wrap_method(
- self.translate_text, default_timeout=None, client_info=_client_info,
+ self.translate_text, default_timeout=600.0, client_info=_client_info,
  ),
  self.detect_language: gapic_v1.method.wrap_method(
- self.detect_language, default_timeout=None, client_info=_client_info,
+ self.detect_language, default_timeout=600.0, client_info=_client_info,
  ),
  self.get_supported_languages: gapic_v1.method.wrap_method(
  self.get_supported_languages,
- default_timeout=None,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
  client_info=_client_info,
  ),
  self.batch_translate_text: gapic_v1.method.wrap_method(
  self.batch_translate_text,
- default_timeout=None,
+ default_timeout=600.0,
  client_info=_client_info,
  ),
  self.create_glossary: gapic_v1.method.wrap_method(
- self.create_glossary, default_timeout=None, client_info=_client_info,
+ self.create_glossary, default_timeout=600.0, client_info=_client_info,
  ),
  self.list_glossaries: gapic_v1.method.wrap_method(
- self.list_glossaries, default_timeout=None, client_info=_client_info,
+ self.list_glossaries,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
+ client_info=_client_info,
  ),
  self.get_glossary: gapic_v1.method.wrap_method(
- self.get_glossary, default_timeout=None, client_info=_client_info,
+ self.get_glossary,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
+ client_info=_client_info,
  ),
  self.delete_glossary: gapic_v1.method.wrap_method(
- self.delete_glossary, default_timeout=None, client_info=_client_info,
+ self.delete_glossary,
+ default_retry=retries.Retry(
+ initial=0.1,
+ maximum=60.0,
+ multiplier=1.3,
+ predicate=retries.if_exception_type(
+ exceptions.DeadlineExceeded, exceptions.ServiceUnavailable,
+ ),
+ ),
+ default_timeout=600.0,
+ client_info=_client_info,
  ),
  }