"operationState": "operation_states",
"operation": "operation_types"
}
- subscriptions_filter = {v + "__contains": notification[k] for k, v in filters.iteritems()}
+ subscriptions_filter = {v + "__contains": notification[k] for k, v in list(filters.items())}
subscriptions = SubscriptionModel.objects.filter(**subscriptions_filter)
if not subscriptions.exists():
},
'cpInstanceId': port.portid # TODO: port.cpinstanceid is not initiated when create port resource.
})
- for network_id, ext_link_ports in ext_connectivity_map.items():
+ for network_id, ext_link_ports in list(ext_connectivity_map.items()):
networks = NetworkInstModel.objects.filter(networkid=network_id)
net_name = networks[0].name if networks else network_id
network_resource = {
def get_notification_status(operation_state):
- notification_status = const.LCM_NOTIFICATION_STATUS.START
- if operation_state in const.RESULT_RANGE:
- notification_status = const.LCM_NOTIFICATION_STATUS.RESULT
- return notification_status
+ if operation_state == const.OPERATION_STATE_TYPE.STARTING:
+ return const.LCM_NOTIFICATION_STATUS.START
+ return const.LCM_NOTIFICATION_STATUS.RESULT
def prepare_notification(nfinstid, jobid, operation, operation_state):