aboutsummaryrefslogtreecommitdiffstats
path: root/app/discover/events/event_port_add.py
diff options
context:
space:
mode:
authoryayogev <yaronyogev@gmail.com>2018-02-27 17:00:05 +0200
committeryayogev <yaronyogev@gmail.com>2018-02-27 17:00:05 +0200
commit648a394f7a318443dfd82f790f83a79616c26905 (patch)
tree719508e9d99771c3de056a9c2914d461c35fb967 /app/discover/events/event_port_add.py
parent100add41cfe2b987524b190c1c92771a3c4f1d5f (diff)
US3541 merge various fixes to OPNFV branch
timestamp of last commit tt was merged: 26-Jan-2018 16:25. Change-Id: I7b0bf7885d7d0badb81c794a52c480b905d78459 Signed-off-by: yayogev <yaronyogev@gmail.com>
Diffstat (limited to 'app/discover/events/event_port_add.py')
-rw-r--r--app/discover/events/event_port_add.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/app/discover/events/event_port_add.py b/app/discover/events/event_port_add.py
index 9220015..e03db34 100644
--- a/app/discover/events/event_port_add.py
+++ b/app/discover/events/event_port_add.py
@@ -168,7 +168,7 @@ class EventPortAdd(EventBase):
"router": ('Gateways', router_name)}
fetcher = CliFetchVserviceVnics()
- fetcher.set_env(env)
+ fetcher.setup(env=env, origin=self.origin)
namespace = 'q{}-{}'.format(object_type, object_id)
vnic_documents = fetcher.handle_service(host['id'], namespace, enable_cache=False)
if not vnic_documents:
@@ -258,7 +258,7 @@ class EventPortAdd(EventBase):
# update instance
instance_fetcher = ApiFetchHostInstances()
- instance_fetcher.set_env(env)
+ instance_fetcher.setup(env=env, origin=self.origin)
instance_docs = instance_fetcher.get(host_id + '-')
instance = next(filter(lambda i: i['id'] == instance_id, instance_docs), None)
@@ -278,7 +278,7 @@ class EventPortAdd(EventBase):
# set ovs as default type.
vnic_fetcher = CliFetchInstanceVnics()
- vnic_fetcher.set_env(env)
+ vnic_fetcher.setup(env=env, origin=self.origin)
vnic_docs = vnic_fetcher.get(instance_id + '-')
vnic = next(filter(lambda vnic: vnic['mac_address'] == mac_address, vnic_docs), None)
@@ -298,7 +298,7 @@ class EventPortAdd(EventBase):
for fetcher in fetchers_implementing_add_links:
fetcher.add_links()
scanner = Scanner()
- scanner.set_env(env)
+ scanner.setup(env=env, origin=self.origin)
scanner.scan_cliques()
port_document = self.inv.get_by_id(env, port['id'])