diff --git a/inventory_provider/routes/jobs.py b/inventory_provider/routes/jobs.py
index 81e6501f7a4ef335476c3c3f18177ed9257cd07e..c26ab6a588041272a855065d38d13e1d028b4474 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 73b4468a46679d34697985efd34578f455cc6a88..a8ecc42a1e7d29f87bc5dc9198035ee66e95e060 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)