Skip to content

Commit eeb0426

Browse files
committed
Remove 10min timeout from topic stream
1 parent 49185d9 commit eeb0426

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

ydb/_grpc/grpcwrapper/common_utils.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -227,6 +227,7 @@ async def receive(self, timeout: Optional[int] = None) -> Any:
227227
else:
228228
async def get_response():
229229
return await self.from_server_grpc.__anext__()
230+
230231
grpc_message = await asyncio.wait_for(get_response(), timeout)
231232

232233
except (grpc.RpcError, grpc.aio.AioRpcError) as e:

0 commit comments

Comments
 (0)