diff --git a/inventory_provider/routes/testing.py b/inventory_provider/routes/testing.py index d6142eabf95d6e0cede77a4f90ff565b170e812f..4eb2e004db7993c5e0c64e48f4b7dc6b6cf7c92d 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(): - worker.update_interfaces_to_services.delay(use_current=True) +def update_interfaces_to_services_ims_route(): + worker.update_interfaces_to_services_ims.delay(use_current=True) return Response('OK') diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index caf86d95cac95290431d32f27bb5d39308995b0b..a4bbf76a3ae4ddc060194cd8139037eecdeff714 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.apply_asynch(), + update_interfaces_to_services_ims.apply_asynch(), import_unmanaged_interfaces.apply_async() ] @@ -503,9 +503,9 @@ def update_fibre_spans(self, use_current=False): @app.task( - base=InventoryTask, bind=True, name='update_interfaces_to_services') + base=InventoryTask, bind=True, name='update_interfaces_to_services_ims') @log_task_entry_and_exit -def update_interfaces_to_services(self, use_current=False): +def update_interfaces_to_services_ims(self, use_current=False): port_id_services = defaultdict(list) c = InventoryTask.config["ims"]