diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 48058c7cb3d2ad2db081e0a5b5c6d68649eae73f..e76e3f6b882c3892ed8389caf4d5a0a55f69a683 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -14,7 +14,7 @@ from inventory_provider.tasks.app import app from inventory_provider.tasks.common \ import get_next_redis, get_current_redis, \ latch_db, get_latch, set_latch, update_latch_status -from inventory_provider.tasks import data +from inventory_provider.tasks import data, monitor from inventory_provider import config from inventory_provider import environment from inventory_provider.db import db, opsdb @@ -547,7 +547,9 @@ def launch_refresh_cache_all(config): :param config: config structure as defined in config.py :return: """ + _erase_next_db(config) + monitor.clear_joblog(get_current_redis(config)) update_latch_status(config, pending=True)