projects
/
osm
/
NBI.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Bug 1830 fixed: maps completed operations to original operation types
[osm/NBI.git]
/
osm_nbi
/
notifications.py
diff --git
a/osm_nbi/notifications.py
b/osm_nbi/notifications.py
index
63d4ce8
..
22413d0
100644
(file)
--- a/
osm_nbi/notifications.py
+++ b/
osm_nbi/notifications.py
@@
-235,6
+235,14
@@
class NotificationBase:
class NsLcmNotification(NotificationBase):
class NsLcmNotification(NotificationBase):
+ # maps kafka commands of completed operations to the original operation type
+ completed_operation_map = {
+ "INSTANTIATED": "INSTANTIATE",
+ "SCALED": "SCALE",
+ "TERMINATED": "TERMINATE",
+ "UPDATED": "UPDATE",
+ "HEALED": "HEAL",
+ }
# SOL005 response model for nslcm notifications
response_models = {
"NsLcmOperationOccurrenceNotification": {
# SOL005 response model for nslcm notifications
response_models = {
"NsLcmOperationOccurrenceNotification": {
@@
-358,7
+366,8
@@
class NsLcmNotification(NotificationBase):
if op_state:
filter_q["operationStates"].append(op_state)
if command:
if op_state:
filter_q["operationStates"].append(op_state)
if command:
- filter_q["operationTypes"].append(command)
+ op_type = self.completed_operation_map.get(command, command)
+ filter_q["operationTypes"].append(op_type)
# self.logger.debug("Db query is: {}".format(filter_q))
subscribers = []
try:
# self.logger.debug("Db query is: {}".format(filter_q))
subscribers = []
try: