diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index b12548c56407e4be7b952a4a2f8a9ff611fa10fe..beaa8b8a32187c6b70043598c08e72b53bb0c227 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -460,8 +460,7 @@ def update_entry_point(self): (reload_lab_router_config_chorded.s(r) for r in lab_routers), empty_task.si('lab router tasks complete') - )), - collate_netconf_interfaces_all_cache.si().on_error(task_error_handler.s()) + )) ), ), final_task.si().on_error(task_error_handler.s()) @@ -1399,6 +1398,7 @@ def final_task(self): _build_snmp_peering_db(update_callback=self.log_info) _build_juniper_peering_db(update_callback=self.log_info) populate_poller_interfaces_cache(warning_callback=self.log_warning) + collate_netconf_interfaces_all_cache(warning_callback=self.log_warning) latch_db(InventoryTask.config) self.log_info('latched current/next dbs') @@ -1450,7 +1450,6 @@ def populate_poller_interfaces_cache(warning_callback=lambda s: None): r.set(all_cache_key, json.dumps(all_populated_interfaces)) -@app.task(base=InventoryTask, bind=True, name='collate_netconf_interfaces_all_cache') @log_task_entry_and_exit def collate_netconf_interfaces_all_cache(warning_callback=lambda s: None): """