From 3e83ca32d137e4f1f11ecfb0c664eb84b3b7d486 Mon Sep 17 00:00:00 2001 From: Alex Samuel Date: Thu, 23 Jan 2025 12:03:00 -0700 Subject: [PATCH] Handle race against output compression. --- python/apsis/service/api.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/apsis/service/api.py b/python/apsis/service/api.py index 37e3c8f4..aa4716fb 100644 --- a/python/apsis/service/api.py +++ b/python/apsis/service/api.py @@ -314,7 +314,7 @@ async def websocket_output_updates(request, ws, run_id, output_id): with apsis.output_update_publisher.subscription(run_id) as sub: try: output = apsis.outputs.get_output(run_id, output_id) - if start is not None: + if start is not None and output.compression is not None: # Send the output data up to now. msg = output_to_http_message(output, interval=(start, None)) await ws.send(msg)