projects
/
osm
/
NBI.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
adding a test script to send kafka messages
[osm/NBI.git]
/
osm_nbi
/
nbi.py
diff --git
a/osm_nbi/nbi.py
b/osm_nbi/nbi.py
index
0616430
..
a43336d
100644
(file)
--- a/
osm_nbi/nbi.py
+++ b/
osm_nbi/nbi.py
@@
-873,9
+873,9
@@
class Server(object):
# creates nslcmop
indata["lcmOperationType"] = "instantiate"
indata["nsInstanceId"] = _id
# creates nslcmop
indata["lcmOperationType"] = "instantiate"
indata["nsInstanceId"] = _id
- self.engine.new_item(rollback, session, "nslcmops", indata, None)
+
nslcmop_id =
self.engine.new_item(rollback, session, "nslcmops", indata, None)
self._set_location_header(main_topic, version, topic, _id)
self._set_location_header(main_topic, version, topic, _id)
- outdata = {"id": _id}
+ outdata = {"id": _id
, "nslcmop_id": nslcmop_id
}
elif topic == "ns_instances" and item:
indata["lcmOperationType"] = item
indata["nsInstanceId"] = _id
elif topic == "ns_instances" and item:
indata["lcmOperationType"] = item
indata["nsInstanceId"] = _id
@@
-889,8
+889,8
@@
class Server(object):
self._set_location_header(main_topic, version, topic, _id)
indata["lcmOperationType"] = "instantiate"
indata["nsiInstanceId"] = _id
self._set_location_header(main_topic, version, topic, _id)
indata["lcmOperationType"] = "instantiate"
indata["nsiInstanceId"] = _id
- self.engine.new_item(rollback, session, "nsilcmops", indata, kwargs)
- outdata = {"id": _id}
+
nsilcmop_id =
self.engine.new_item(rollback, session, "nsilcmops", indata, kwargs)
+ outdata = {"id": _id
, "nsilcmop_id": nsilcmop_id
}
elif topic == "netslice_instances" and item:
indata["lcmOperationType"] = item
elif topic == "netslice_instances" and item:
indata["lcmOperationType"] = item