diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py index 4a9840fcf4ae7c9c2581f587484a8f346a088621..ee478a1ab4ac6c4e46d28151e60c058a75062890 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)