From 9f6197c0c73edf592bee149c56ec560815c61aad Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Thu, 18 Jul 2019 14:27:56 +0200
Subject: [PATCH] flush next db before running jobs
---
inventory_provider/tasks/worker.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index 33d49fac..88dbfc69 100644
--- a/inventory_provider/tasks/worker.py
+++ b/inventory_provider/tasks/worker.py
@@ -441,6 +441,9 @@ def launch_refresh_cache_all(config):
"""
logger = logging.getLogger(__name__)
+ r = get_next_redis(InventoryTask.config)
+ r.flushdb()
+
# first batch of subtasks: refresh cached opsdb data
subtasks = [
update_junosspace_device_list.apply_async(),
--
GitLab