diff --git a/inventory_provider/routes/testing.py b/inventory_provider/routes/testing.py index 4eb2e004db7993c5e0c64e48f4b7dc6b6cf7c92d..0bb10a10eff3a77cb8e8e9e62ef258963ceb04e0 100644 --- a/inventory_provider/routes/testing.py +++ b/inventory_provider/routes/testing.py @@ -22,8 +22,8 @@ def flushdb(): @routes.route("update-interfaces-to-services", methods=['GET', 'POST']) -def update_interfaces_to_services_ims_route(): - worker.update_interfaces_to_services_ims.delay(use_current=True) +def update_interfaces_to_services_route(): + worker.update_interfaces_to_services.delay(use_current=True) return Response('OK') diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index a4bbf76a3ae4ddc060194cd8139037eecdeff714..899639c7e462d0d6a11111e1f73a24b077e2bf45 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -453,7 +453,7 @@ def internal_refresh_phase_2(self): subtasks = [ update_circuit_hierarchy.apply_async(), - update_interfaces_to_services_ims.apply_asynch(), + update_interfaces_to_services.apply_async(), import_unmanaged_interfaces.apply_async() ] @@ -505,7 +505,7 @@ def update_fibre_spans(self, use_current=False): @app.task( base=InventoryTask, bind=True, name='update_interfaces_to_services_ims') @log_task_entry_and_exit -def update_interfaces_to_services_ims(self, use_current=False): +def update_interfaces_to_services(self, use_current=False): port_id_services = defaultdict(list) c = InventoryTask.config["ims"]