From f35b9b9e262d91d22282ceb764268995872d04c7 Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Fri, 1 Feb 2019 15:57:40 +0100
Subject: [PATCH] disable unused alarmsdb table backup job
---
inventory_provider/db/alarmsdb.py | 4 ++--
inventory_provider/routes/jobs.py | 18 +++++++++---------
inventory_provider/tasks/worker.py | 20 ++++++++++----------
3 files changed, 21 insertions(+), 21 deletions(-)
diff --git a/inventory_provider/db/alarmsdb.py b/inventory_provider/db/alarmsdb.py
index 597b47ff..23e1e924 100644
--- a/inventory_provider/db/alarmsdb.py
+++ b/inventory_provider/db/alarmsdb.py
@@ -69,5 +69,5 @@ def _load_juniper_servers_table(connection):
}
-def load_cache(connection):
- yield "juniper_servers", list(_load_juniper_servers_table(connection))
+# def load_cache(connection):
+# yield "juniper_servers", list(_load_juniper_servers_table(connection))
diff --git a/inventory_provider/routes/jobs.py b/inventory_provider/routes/jobs.py
index 7ca93f20..12f3616b 100644
--- a/inventory_provider/routes/jobs.py
+++ b/inventory_provider/routes/jobs.py
@@ -37,15 +37,15 @@ def update():
return Response("OK")
-@routes.route("/update-startup", methods=['GET', 'POST'])
-def startup_update():
- task_logger = logging.getLogger(TASK_LOGGER_NAME)
- task_logger.debug(
- 'launching task: '
- 'inventory_provider.tasks.worker.update_alarmsdb_cache')
- app.send_task(
- 'inventory_provider.tasks.worker.update_alarmsdb_cache')
- return Response("OK")
+# @routes.route("/update-startup", methods=['GET', 'POST'])
+# def startup_update():
+# task_logger = logging.getLogger(TASK_LOGGER_NAME)
+# task_logger.debug(
+# 'launching task: '
+# 'inventory_provider.tasks.worker.update_alarmsdb_cache')
+# app.send_task(
+# 'inventory_provider.tasks.worker.update_alarmsdb_cache')
+# return Response("OK")
@routes.route("update-interfaces-to-services", methods=['GET'])
diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index 50a202a4..e01e15f9 100644
--- a/inventory_provider/tasks/worker.py
+++ b/inventory_provider/tasks/worker.py
@@ -128,16 +128,16 @@ def netconf_refresh_config(self, hostname):
logger.debug('FINISHED: netconf_refresh_config(%r)' % hostname)
-@app.task(bind=InventoryTask)
-def update_alarmsdb_cache(self):
- logger = logging.getLogger(constants.TASK_LOGGER_NAME)
- logger.debug('STARTING: update_alarmsdb_cache')
-
- with db.connection(InventoryTask.config["alarms-db"]) as cx:
- for table_name, data in alarmsdb.load_cache(cx):
- InventoryTask.save_value_json('alarmsdb:%s' % table_name, data)
-
- logger.debug('FINISHED: update_alarmsdb_cache')
+# @app.task(bind=InventoryTask)
+# def update_alarmsdb_cache(self):
+# logger = logging.getLogger(constants.TASK_LOGGER_NAME)
+# logger.debug('STARTING: update_alarmsdb_cache')
+#
+# with db.connection(InventoryTask.config["alarms-db"]) as cx:
+# for table_name, data in alarmsdb.load_cache(cx):
+# InventoryTask.save_value_json('alarmsdb:%s' % table_name, data)
+#
+# logger.debug('FINISHED: update_alarmsdb_cache')
@app.task()
--
GitLab