X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=a1%2Fa1rmr.py;h=3d0ff9535ca3df98cdf7d77ca6bca0ed53999bf1;hb=2c1c4e9dd207289bbdc3453bfdb3e2dad68df8a8;hp=771842a978feae899cbcd338bbbf01b6aefd75c9;hpb=b6ff2b49aa9e3cc35dd35ce036440af19cdc80b8;p=ric-plt%2Fa1.git

diff --git a/a1/a1rmr.py b/a1/a1rmr.py
index 771842a..3d0ff95 100644
--- a/a1/a1rmr.py
+++ b/a1/a1rmr.py
@@ -22,7 +22,7 @@ import queue
 import time
 import json
 from threading import Thread
-from rmr import rmr, helpers
+from ricxappframe.rmr import rmr, helpers
 from mdclogpy import Logger
 from a1 import data, messages
 from a1.exceptions import PolicyTypeNotFound, PolicyInstanceNotFound
@@ -45,6 +45,8 @@ class _RmrLoop:
     """
     class represents an rmr loop that constantly reads from rmr and performs operations based on waiting messages
     this launches a thread, it should probably only be called once; the public facing method to access these ensures this
+
+    TODO: the xapp frame has a version of this looping structure. See if A1 can switch to that.
     """
 
     def __init__(self, init_func_override=None, rcv_func_override=None):