From a784e5eb11e97ddfe379db6a55511b591c0386bf Mon Sep 17 00:00:00 2001 From: riteshghorse Date: Thu, 7 Dec 2023 11:40:58 -0500 Subject: [PATCH] add SECS suffix --- sdks/python/apache_beam/io/requestresponseio.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/sdks/python/apache_beam/io/requestresponseio.py b/sdks/python/apache_beam/io/requestresponseio.py index 062c7be4110b..9a3cf93aefae 100644 --- a/sdks/python/apache_beam/io/requestresponseio.py +++ b/sdks/python/apache_beam/io/requestresponseio.py @@ -31,7 +31,7 @@ RequestT = TypeVar('RequestT') ResponseT = TypeVar('ResponseT') -DEFAULT_TIMEOUT = 30 # seconds +DEFAULT_TIMEOUT_SECS = 30 # seconds _LOGGER = logging.getLogger(__name__) @@ -157,9 +157,9 @@ class _Call(beam.PTransform[beam.PCollection[RequestT], of the input PCollection. This PTransform uses a `Caller` object to invoke the actual API calls, - and employs a `SetupTeardown` object to manage setup and teardown of clients - when applicable. Additionally, a timeout value is specified to regulate the - duration of each call, defaults to 30 seconds. + and uses ``__enter__`` and ``__exit__`` to manage setup and teardown of + clients when applicable. Additionally, a timeout value is specified to + regulate the duration of each call, defaults to 30 seconds. Args: caller (:class:`apache_beam.io.requestresponseio.Caller`): a callable