diff --git a/inventory_provider/db/alarmsdb.py b/inventory_provider/db/alarmsdb.py index 597b47ff36fd1f70e566c158873ef9f9b8a273c1..23e1e9249c48cb4c6594aa52b3d5480c3dbf1f53 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 7ca93f20107845302d2fad0c3084ae95670bcacd..12f3616b6869c08b6f45f34ac5f9be0e757e258b 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 50a202a427b38967a266e4836e1320059d194028..e01e15f9c74a73110334590206e5936ba39d0a13 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()