From fa9d755b26778e47ae59eaa6d956758eb35a0dc4 Mon Sep 17 00:00:00 2001
From: Thomas Kluyver <thomas@kluyver.me.uk>
Date: Fri, 6 May 2022 11:21:23 +0100
Subject: [PATCH] Use module specific logger in more places
---
webservice/job_monitor.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py
index 4a9840fcf..ee478a1ab 100644
--- a/webservice/job_monitor.py
+++ b/webservice/job_monitor.py
@@ -38,7 +38,7 @@ def init_kafka_producer(config):
max_block_ms=2000, # Don't get stuck trying to send Kafka messages
)
except KafkaError:
- logging.warning("Problem initialising Kafka producer; "
+ log.warning("Problem initialising Kafka producer; "
"Kafka notifications will not be sent.", exc_info=True)
return NoOpProducer()
@@ -79,7 +79,7 @@ def slurm_job_status(jobid):
if res.returncode == 0:
rlines = res.stdout.decode().split("\n")
- logging.debug("Job {} state {}".format(jobid, rlines[2].split()))
+ log.debug("Job {} state {}".format(jobid, rlines[2].split()))
if len(rlines[2].split()) == 3:
return rlines[2].replace("+", "").split()
return "NA", "NA", "NA"
@@ -90,7 +90,7 @@ def update_job_db(config):
:param config: configuration parsed from webservice YAML
"""
- log.info("Starting config db handling")
+ log.info("Starting jobs monitor")
conn = init_job_db(config)
mdc = init_md_client(config)
kafka_prod = init_kafka_producer(config)
--
GitLab