diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 4e67dc966ad3be196b8f99331927962d6c043747..91c83f14abd65b80d9c45e3484dfc9612ab4ae20 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -459,7 +459,8 @@ 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.s().on_error(task_error_handler.s()) ), final_task.si().on_error(task_error_handler.s()) )() @@ -1447,6 +1448,7 @@ 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): """