X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=a1%2Fmessages.py;h=36630530543072f14ce5fba7dbe713e5be176198;hb=f0ac3fb27a3bda65076f790def3284065c95b098;hp=cbcea08a18f46d36aecbe945b55026767e15e28c;hpb=9d5ad7161f64346c17e9c466bf1992e4257e9bde;p=ric-plt%2Fa1.git

diff --git a/a1/messages.py b/a1/messages.py
index cbcea08..3663053 100644
--- a/a1/messages.py
+++ b/a1/messages.py
@@ -1,6 +1,3 @@
-"""
-rmr messages
-"""
 # ==================================================================================
 #       Copyright (c) 2019 Nokia
 #       Copyright (c) 2018-2019 AT&T Intellectual Property.
@@ -17,6 +14,9 @@ rmr messages
 #   See the License for the specific language governing permissions and
 #   limitations under the License.
 # ==================================================================================
+"""
+rmr messages
+"""
 
 
 def a1_to_handler(operation, policy_type_id, policy_instance_id, payload=None):
@@ -29,3 +29,13 @@ def a1_to_handler(operation, policy_type_id, policy_instance_id, payload=None):
         "policy_instance_id": policy_instance_id,
         "payload": payload,
     }
+
+
+def ei_to_handler(ei_job_id, payload=None):
+    """
+    used to create the payloads that get sent to downstream policy handlers
+    """
+    return {
+        "ei_job_id": ei_job_id,
+        "payload": payload,
+    }