Use module specific logger in more places

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)