Skip to content

Commit 914939f

Browse files
committed
formatting
1 parent 8e12641 commit 914939f

File tree

1 file changed

+5
-3
lines changed
  • inference/core/interfaces/webrtc_worker

1 file changed

+5
-3
lines changed

inference/core/interfaces/webrtc_worker/webrtc.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,6 @@ class VideoFileUploadHandler:
147147
"""
148148

149149
def __init__(self):
150-
151150
self._chunks: Dict[int, bytes] = {}
152151
self._total_chunks: Optional[int] = None
153152
self._temp_file_path: Optional[str] = None
@@ -168,7 +167,9 @@ def handle_chunk(self, chunk_index: int, total_chunks: int, data: bytes) -> None
168167
self._chunks[chunk_index] = data
169168

170169
if chunk_index % 100 == 0:
171-
logger.info("Upload progress: %s/%s chunks", len(self._chunks), total_chunks)
170+
logger.info(
171+
"Upload progress: %s/%s chunks", len(self._chunks), total_chunks
172+
)
172173

173174
# Auto-complete when all chunks received
174175
# TODO: Handle the file writing without keeping all chunks in memory
@@ -244,7 +245,8 @@ async def send_chunked_data(
244245
sleep_count += 1
245246
if sleep_count % 10 == 0:
246247
logger.debug(
247-
"Waiting for data channel buffer to drain. Data channel buffer size: %s", data_channel.bufferedAmount
248+
"Waiting for data channel buffer to drain. Data channel buffer size: %s",
249+
data_channel.bufferedAmount,
248250
)
249251
if heartbeat_callback:
250252
heartbeat_callback()

0 commit comments

Comments
 (0)