diff --git a/cirq-google/cirq_google/engine/stream_manager.py b/cirq-google/cirq_google/engine/stream_manager.py index 7c3539b274c..174af64f8cf 100644 --- a/cirq-google/cirq_google/engine/stream_manager.py +++ b/cirq-google/cirq_google/engine/stream_manager.py @@ -205,9 +205,9 @@ async def _manage_stream( """ while True: try: - # The default gRPC client timeout is used. response_iterable = await self._grpc_client.quantum_run_stream( - _request_iterator(request_queue) + _request_iterator(request_queue), + timeout=None, # Persist the stream indefinitely. ) async for response in response_iterable: self._response_demux.publish(response)