from osm_common.msgbase import MsgException
from osm_ng_ro.ns_thread import deep_get, NsWorker, NsWorkerException
from osm_ng_ro.validation import deploy_schema, validate_input
from osm_common.msgbase import MsgException
from osm_ng_ro.ns_thread import deep_get, NsWorker, NsWorkerException
from osm_ng_ro.validation import deploy_schema, validate_input
affinity_group = {}
for affinity_group_id in existing_vdu["affinity-or-anti-affinity-group-id"]:
for group in db_nsr.get("affinity-or-anti-affinity-group"):
affinity_group = {}
for affinity_group_id in existing_vdu["affinity-or-anti-affinity-group-id"]:
for group in db_nsr.get("affinity-or-anti-affinity-group"):
- if group["id"] == affinity_group_id and group["vim_info"][target_id].get("vim_id", None) is not None:
- affinity_group["affinity_group_id"] = group["vim_info"][target_id].get("vim_id", None)
+ if (
+ group["id"] == affinity_group_id
+ and group["vim_info"][target_id].get("vim_id", None) is not None
+ ):
+ affinity_group["affinity_group_id"] = group["vim_info"][
+ target_id
+ ].get("vim_id", None)
self.logger.debug("Updating database, Creating ro_tasks")
db_ro_task = Ns._create_ro_task(target_id, db_task)
self.logger.debug("Updating database, Creating ro_tasks")
db_ro_task = Ns._create_ro_task(target_id, db_task)
# So remove all task related to target record.
ro_tasks = self.db.get_list("ro_tasks", {"tasks.nsr_id": nsr_id})
for change in changes_list:
# So remove all task related to target record.
ro_tasks = self.db.get_list("ro_tasks", {"tasks.nsr_id": nsr_id})
for change in changes_list:
step = "Updating database, Appending tasks to ro_tasks"
self.upload_recreate_tasks(
db_new_tasks=db_new_tasks,
step = "Updating database, Appending tasks to ro_tasks"
self.upload_recreate_tasks(
db_new_tasks=db_new_tasks,