summaryrefslogtreecommitdiffstats
path: root/conductor/conductor/data/plugins/inventory_provider/aai.py
diff options
context:
space:
mode:
Diffstat (limited to 'conductor/conductor/data/plugins/inventory_provider/aai.py')
-rw-r--r--conductor/conductor/data/plugins/inventory_provider/aai.py8
1 files changed, 7 insertions, 1 deletions
diff --git a/conductor/conductor/data/plugins/inventory_provider/aai.py b/conductor/conductor/data/plugins/inventory_provider/aai.py
index bdc74bc..7bbbe68 100644
--- a/conductor/conductor/data/plugins/inventory_provider/aai.py
+++ b/conductor/conductor/data/plugins/inventory_provider/aai.py
@@ -38,6 +38,7 @@ from conductor.data.plugins.inventory_provider.candidates.nxi_candidate import N
from conductor.data.plugins.inventory_provider.candidates.service_candidate import Service
from conductor.data.plugins.inventory_provider.candidates.transport_candidate import Transport
from conductor.data.plugins.inventory_provider.candidates.vfmodule_candidate import VfModule
+from conductor.data.plugins.inventory_provider.dcae import DCAE
from conductor.data.plugins.inventory_provider import hpa_utils
from conductor.data.plugins.inventory_provider.sdc import SDC
from conductor.data.plugins.inventory_provider.utils import aai_utils
@@ -1889,6 +1890,7 @@ class AAI(base.InventoryProviderBase):
def filter_nxi_candidates(self, response_body, filtering_attributes, default_attributes, candidate_uniqueness,
type):
+ required_candidates = list()
candidates = list()
if response_body is not None:
nxi_instances = response_body.get("service-instance", [])
@@ -1915,7 +1917,11 @@ class AAI(base.InventoryProviderBase):
default_fields=aai_utils.convert_hyphen_to_under_score(default_attributes))
candidate = nxi_candidate.convert_nested_dict_to_dict()
candidates.append(candidate)
- return candidates
+ LOG.debug("AAI candidates before adding capacity attributes ", candidates)
+ capacity_filtered_candidates = DCAE().capacity_filter(candidates)
+ required_candidates = capacity_filtered_candidates
+ LOG.debug("updated candidate from DCAE class ", required_candidates)
+ return required_candidates
def get_profile_instances(self, nxi_instance):
slice_role = nxi_instance['service-role']