From a4429f1be472dad0baefb5f22e6699994ea0cad5 Mon Sep 17 00:00:00 2001
From: Erik Reid <erik.reid@geant.org>
Date: Thu, 7 Feb 2019 21:21:00 +0100
Subject: [PATCH] correct celery calling convention
---
inventory_provider/routes/jobs.py | 4 ++--
inventory_provider/tasks/worker.py | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/inventory_provider/routes/jobs.py b/inventory_provider/routes/jobs.py
index 81e6501f..c26ab6a5 100644
--- a/inventory_provider/routes/jobs.py
+++ b/inventory_provider/routes/jobs.py
@@ -13,11 +13,11 @@ def update():
@routes.route("update-interface-statuses")
def update_interface_statuses():
- worker.update_interface_statuses().async_start()
+ worker.update_interface_statuses.delay()
return Response("OK")
@routes.route("reload-router-config/<equipment_name>")
def reload_router_config(equipment_name):
- worker.reload_router_config().async_start(equipment_name)
+ worker.reload_router_config.delay(equipment_name)
return Response("OK")
diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py
index 73b4468a..a8ecc42a 100644
--- a/inventory_provider/tasks/worker.py
+++ b/inventory_provider/tasks/worker.py
@@ -277,7 +277,7 @@ def reload_router_config(hostname):
task_logger = logging.getLogger(constants.TASK_LOGGER_NAME)
task_logger.debug('>>> update_router_config')
- netconf_refresh_config.apply(hostname)
+ netconf_refresh_config.apply(args=[hostname])
netconf_doc = load_netconf_data(hostname)
if netconf_doc is None:
@@ -292,7 +292,7 @@ def reload_router_config(hostname):
task_logger.error(
'error extracting community string for %r' % hostname)
else:
- snmp_refresh_interfaces.apply(args=(hostname, community))
+ snmp_refresh_interfaces.apply(args=[hostname, community])
# TODO: move this out of else? (i.e. clear even if netconf fails?)
clear_cached_classifier_responses(hostname)
--
GitLab