From f29323666fa894564b78213dca9213436993c412 Mon Sep 17 00:00:00 2001 From: Michael Qian Date: Tue, 22 Jul 2025 13:52:38 -0700 Subject: [PATCH] Restore behavior which persists `quantum_run_stream`s indefinitely --- cirq-google/cirq_google/engine/stream_manager.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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)