From 41618bfef52c37c8d9a30769a1dc8a5decffaf7a Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Sun, 23 Dec 2018 21:07:18 +0100
Subject: [PATCH] don't call router_details.update_router_details
---
inventory_provider/routes/jobs.py | 19 +++++++++++++++++--
1 file changed, 17 insertions(+), 2 deletions(-)
diff --git a/inventory_provider/routes/jobs.py b/inventory_provider/routes/jobs.py
index 41f8b7a0..db71dfe2 100644
--- a/inventory_provider/routes/jobs.py
+++ b/inventory_provider/routes/jobs.py
@@ -1,12 +1,27 @@
+import logging
from flask import Blueprint, Response, current_app
from inventory_provider import router_details
+from inventory_provider.tasks.app import app
+from inventory_provider.constants import TASK_LOGGER_NAME
routes = Blueprint("inventory-data-job-routes", __name__)
@routes.route("/update", methods=['GET', 'POST'])
def update():
- router_details.update_network_details(
- current_app.config["INVENTORY_PROVIDER_CONFIG"])
+
+ task_logger = logging.getLogger(TASK_LOGGER_NAME)
+ config = current_app.config["INVENTORY_PROVIDER_CONFIG"]
+
+ for r in config["routers"]:
+ task_logger.info("fetching router details for: %r" % r)
+ task_logger.debug('launching task: '
+ 'inventory_provider'
+ '.tasks.worker.netconf_refresh_config'
+ '(%s)' % r['hostname'])
+ app.send_task(
+ 'inventory_provider.tasks.worker.netconf_refresh_config',
+ args=[r["hostname"]])
+
return Response("OK")
--
GitLab