Rename A1 policy metrics

[ric-plt/a1.git] / a1 / a1rmr.py

diff --git a/a1/a1rmr.py b/a1/a1rmr.py
index 5a300e8..e4a7448 100644 (file)
--- a/a1/a1rmr.py
+++ b/a1/a1rmr.py
@@ -28,7 +28,8 @@ from mdclogpy import Logger
 from a1 import data, messages
 from a1.exceptions import PolicyTypeNotFound, PolicyInstanceNotFound
 
-mdc_logger = Logger(name=__name__)
+mdc_logger = Logger()
+mdc_logger.mdclog_format_init(configmap_monitor=True)
 
 
 # With Nanomsg and NNG it was possible for a send attempt to have a "soft"
@@ -172,7 +173,7 @@ class _RmrLoop:
 
             work_item = self.ei_job_result_queue.get(block=False, timeout=None)
             payload = json.dumps(messages.ei_to_handler(*work_item)).encode("utf-8")
-            ei_job_id = int(payload.get("ei_job_id"))
+            ei_job_id = int(work_item[0])
             mdc_logger.debug("data-delivery: {}".format(payload))
 
             # send the payload to consumer subscribed for ei_job_id
@@ -323,9 +324,8 @@ def queue_ei_job_result(item):
     """
     push an item into the ei_job_queue
     """
-    mdc_logger.debug("before queue {0}".format(item))
+    mdc_logger.debug("queuing data delivery item {0}".format(item))
     __RMR_LOOP__.ei_job_result_queue.put(item)
-    mdc_logger.debug("after queue")
 
 
 def healthcheck_rmr_thread(seconds=30):