From ef75d4b5343c8e4696e2e77816e91120ecff63bb Mon Sep 17 00:00:00 2001 From: Tian Gao Date: Fri, 6 Feb 2026 14:01:19 -0800 Subject: [PATCH] Always raise KeyboardInterrupt from SIGINT handler --- python/pyspark/core/context.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/python/pyspark/core/context.py b/python/pyspark/core/context.py index 54e955318caa7..78cf7f1413129 100644 --- a/python/pyspark/core/context.py +++ b/python/pyspark/core/context.py @@ -405,8 +405,10 @@ def _do_init( # create a signal handler which would be invoked on receiving SIGINT def signal_handler(signal: Any, frame: Any) -> NoReturn: - self.cancelAllJobs() - raise KeyboardInterrupt() + try: + self.cancelAllJobs() + finally: + raise KeyboardInterrupt() # see http://stackoverflow.com/questions/23206787/ if isinstance(