From 36b5f906eaef83178d50263ba659700eec82da5c Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Thu, 4 Jun 2020 11:47:52 +0200
Subject: [PATCH] clear joblog records from current db before refresh
---
inventory_provider/tasks/worker.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index 48058c7c..e76e3f6b 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)
--
GitLab