X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=NG-RO%2Fosm_ng_ro%2Fns_thread.py;h=94af5a17836364606f551e73682296e13a6dcfcd;hb=refs%2Ftags%2Fbranch-bug1511-start;hp=f15831aab94fd04e083bb8e3409d75c5d545d6c0;hpb=2ad85177bbd65b42317c378fdb7affbfd97b54cf;p=osm%2FRO.git diff --git a/NG-RO/osm_ng_ro/ns_thread.py b/NG-RO/osm_ng_ro/ns_thread.py index f15831aa..94af5a17 100644 --- a/NG-RO/osm_ng_ro/ns_thread.py +++ b/NG-RO/osm_ng_ro/ns_thread.py @@ -921,7 +921,7 @@ class VimInteractionSdnNet(VimInteractionBase): else None, "service_endpoint_encapsulation_info": { "vlan": port.get("vlan"), - "mac": port.get("mac_address"), + "mac": port.get("mac-address"), "device_id": pmap.get("device_id") or port["compute_node"], "device_interface_id": pmap.get("device_interface_id") or port["pci"], @@ -1758,6 +1758,11 @@ class NsWorker(threading.Thread): next_check_at = min( next_check_at, dependency_ro_task["to_check_at"] ) + # must allow dependent task to be processed first + # to do this set time after last_task_processed + next_check_at = max( + self.time_last_task_processed, next_check_at + ) break elif dependency_task["status"] == "FAILED": error_text = "Cannot {} {} because depends on failed {} {} id={}): {}".format(