From 4bc30b7ecff4f662fedb3ad518a62e5d1e3e64e0 Mon Sep 17 00:00:00 2001
From: Ian Grant <ian.conway.grant@gmail.com>
Date: Wed, 14 May 2025 20:49:13 -0400
Subject: [PATCH] style: replace print statements with logging calls in
JobManager.py
---
maap_utils/JobManager.py | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/maap_utils/JobManager.py b/maap_utils/JobManager.py
index af89c63..61377de 100644
--- a/maap_utils/JobManager.py
+++ b/maap_utils/JobManager.py
@@ -151,7 +151,7 @@ class JobManager:
self.ledger.remove_job(job.job_id)
# Submit new jobs
- logging.info(f"Resubmitting {len(new_jobs)} failed jobs")
+ logging.info(f"Resubmitting {len(new_jobs)} failed jobs...")
for job in new_jobs:
try:
job.submit()
@@ -171,12 +171,13 @@ class JobManager:
)
try:
time.sleep(3)
- print("Resuming monitoring...")
+ logging.info("Resuming monitoring...")
self.monitor()
except KeyboardInterrupt:
if self.redo_enabled and self.prompt_for_redo():
- print("Resubmitting failed jobs...")
+ logging.info("Resubmitting failed jobs...")
self.resubmit_jobs()
+ logging.info("Resuming monitoring...")
self.monitor()
else:
self.exit_gracefully()
@@ -199,7 +200,7 @@ class JobManager:
def exit_gracefully(self) -> None:
"""Cancel pending jobs, print a report, and exit"""
- print("\nExiting...")
+ logging.info("\nExiting gracefully...")
# Cancel all pending jobs
pending_jobs = self.ledger.get_pending_jobs()
@@ -208,7 +209,7 @@ class JobManager:
job.cancel()
except Exception as e:
logging.error(f"Error cancelling job: {e}")
- print("All jobs cancelled.")
+ logging.info("All pending jobs cancelled.")
self.report()
exit(0)
--
GitLab