From 258a66b50915e511142400300a33d28226e9be76 Mon Sep 17 00:00:00 2001
From: "Ian Grant (aider)" <ian.conway.grant@gmail.com>
Date: Fri, 16 May 2025 19:03:53 -0400
Subject: [PATCH] fix: propagate KeyboardInterrupt in Job and
JobManager.submit()
---
maap_utils/Job.py | 2 ++
maap_utils/JobManager.py | 2 ++
2 files changed, 4 insertions(+)
diff --git a/maap_utils/Job.py b/maap_utils/Job.py
index bbf5dca..5fa314d 100644
--- a/maap_utils/Job.py
+++ b/maap_utils/Job.py
@@ -31,6 +31,8 @@ class Job:
"""Call a MAAP function, catch and log exceptions."""
try:
return fn(*args, **kwargs)
+ except KeyboardInterrupt:
+ raise
except Exception as e:
logging.error(f"MAAP API error in {fn.__name__}: {e}")
return None
diff --git a/maap_utils/JobManager.py b/maap_utils/JobManager.py
index 460778a..4c07e70 100644
--- a/maap_utils/JobManager.py
+++ b/maap_utils/JobManager.py
@@ -54,6 +54,8 @@ class JobManager:
job.submit()
self.ledger.add_job(job)
job_batch_counter += 1
+ except KeyboardInterrupt:
+ raise
except Exception as e:
logging.error(f"Error submitting job: {e}")
continue
--
GitLab