diff --git a/inventory_provider/tasks/ims_worker.py b/inventory_provider/tasks/ims_worker.py index 97338c5865fea959063db3d0e6a8efea528d3922..7e0e7454e79bc4c776f64522b35a4182868f0a28 100644 --- a/inventory_provider/tasks/ims_worker.py +++ b/inventory_provider/tasks/ims_worker.py @@ -81,10 +81,11 @@ def internal_refresh_phase_2_ims(self): r = get_next_redis(InventoryTask.config) routers = r.get('netdash') assert routers + netdash_equipment = json.loads(routers.decode('utf-8')) # for hostname in data.derive_router_hostnames(InventoryTask.config): - for hostname in routers: + for hostname in netdash_equipment: logger.debug(f'queueing router refresh jobs for {hostname}') - subtasks.append(reload_router_config.apply_async(args=[hostname])) + # subtasks.append(reload_router_config.apply_async(args=[hostname])) pending_task_ids = [x.id for x in subtasks]