Skip to content

Commit c37af7d

Browse files
committed
feat: rename _DEFAULT_PUT_TIMEOUT to _DEFAULT_PUT_TIMEOUT_SECONDS in _stream_multiplexer.py
1 parent 0063aaa commit c37af7d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

packages/google-cloud-storage/google/cloud/storage/asyncio/_stream_multiplexer.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
logger = logging.getLogger(__name__)
2727

2828
_DEFAULT_QUEUE_MAX_SIZE = 100
29-
_DEFAULT_PUT_TIMEOUT = 20.0
29+
_DEFAULT_PUT_TIMEOUT_SECONDS = 20.0
3030

3131

3232
class _StreamError:
@@ -87,7 +87,7 @@ def _get_unique_queues(self) -> Set[asyncio.Queue]:
8787

8888
async def _put_with_timeout(self, queue: asyncio.Queue, item) -> None:
8989
try:
90-
await asyncio.wait_for(queue.put(item), timeout=_DEFAULT_PUT_TIMEOUT)
90+
await asyncio.wait_for(queue.put(item), timeout=_DEFAULT_PUT_TIMEOUT_SECONDS)
9191
except asyncio.TimeoutError:
9292
if queue not in self._get_unique_queues():
9393
logger.debug("Dropped item for unregistered queue.")

0 commit comments

Comments
 (0)