Skip to content

Commit f293d75

Browse files
commonwealth: bump default timeout_streamer timeout to 10min
1 parent 3aeedcc commit f293d75

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/libs/commonwealth/src/commonwealth/utils/streaming.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ async def _fetch_stream(
9696
await queue.put((None, None))
9797

9898

99-
async def timeout_streamer(gen: AsyncGenerator[str | bytes, None], timeout: int = 3) -> AsyncGenerator[str, None]:
99+
async def timeout_streamer(gen: AsyncGenerator[str | bytes, None], timeout: int = 10) -> AsyncGenerator[str, None]:
100100
"""
101101
Streamer wrapper for async generators and provide a consistent response format
102102
with error handling with additional timeout limit for each item iteration.

0 commit comments

Comments
 (0)