From d2ecce75292944890f0928862db80f57dc8c291c Mon Sep 17 00:00:00 2001 From: Praveen Ghuge Date: Sun, 26 Apr 2026 22:02:28 +0530 Subject: [PATCH] style: black format uploader.py --- litellm/integrations/mavvrik/uploader.py | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/litellm/integrations/mavvrik/uploader.py b/litellm/integrations/mavvrik/uploader.py index af553c37c5b..eedffca3f8b 100644 --- a/litellm/integrations/mavvrik/uploader.py +++ b/litellm/integrations/mavvrik/uploader.py @@ -204,23 +204,31 @@ class Uploader: while len(gz_buffer) >= _GCS_CHUNK_SIZE: chunk = bytes(gz_buffer[:_GCS_CHUNK_SIZE]) gz_buffer = gz_buffer[_GCS_CHUNK_SIZE:] - await self._put_chunk(session_uri, chunk, offset=offset, final=False) + await self._put_chunk( + session_uri, chunk, offset=offset, final=False + ) offset += len(chunk) if not has_data: - verbose_proxy_logger.debug("uploader: no data to stream, skipping upload") + verbose_proxy_logger.debug( + "uploader: no data to stream, skipping upload" + ) return 0 gz.close() gz_buffer.extend(raw_buf.getvalue()) total = offset + len(gz_buffer) - await self._put_chunk(session_uri, bytes(gz_buffer), offset=offset, final=True) + await self._put_chunk( + session_uri, bytes(gz_buffer), offset=offset, final=True + ) except Exception: # Cancel the open GCS session so it doesn't linger for up to 1 week. if session_uri: with contextlib.suppress(Exception): - await http_request("DELETE", session_uri, timeout=10.0, label="cancel") + await http_request( + "DELETE", session_uri, timeout=10.0, label="cancel" + ) raise verbose_proxy_logger.info(