diff --git a/hail/python/hail/backend/service_backend.py b/hail/python/hail/backend/service_backend.py index e89ba2c912a..15b42fe0e8b 100644 --- a/hail/python/hail/backend/service_backend.py +++ b/hail/python/hail/backend/service_backend.py @@ -481,6 +481,7 @@ def _cancel_on_ctrl_c(self, coro: Awaitable[T]) -> T: if self._batch is not None: print("Received a keyboard interrupt, cancelling the batch...") async_to_blocking(self._batch.cancel()) + self._batch = None raise def execute(self, ir: BaseIR, timed: bool = False):