diff --git a/inventory_provider/tasks/ims_worker.py b/inventory_provider/tasks/ims_worker.py index 774d435401d01de213ea9ed83e84c6ca39b6c070..a248c69abc409b9bfcaacf4b2ba9b9614f9b90cc 100644 --- a/inventory_provider/tasks/ims_worker.py +++ b/inventory_provider/tasks/ims_worker.py @@ -77,7 +77,12 @@ def internal_refresh_phase_2_ims(self): update_port_ids_to_services_ims.apply_async(), import_unmanaged_interfaces.apply_async() ] - for hostname in data.derive_router_hostnames(InventoryTask.config): + + r = get_next_redis(config) + routers = r.get('netdash') + assert routers + # for hostname in data.derive_router_hostnames(InventoryTask.config): + for hostname in routers: logger.debug(f'queueing router refresh jobs for {hostname}') subtasks.append(reload_router_config.apply_async(args=[hostname]))