Skip to content
Snippets Groups Projects
Commit f35b9b9e authored by Erik Reid's avatar Erik Reid
Browse files

disable unused alarmsdb table backup job

parent 8f951aa5
No related branches found
No related tags found
No related merge requests found
......@@ -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))
......@@ -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'])
......
......@@ -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()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment