diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 685cf38174ddd71b8e42eb1e18520e4595c83fd2..24df40475263809bbe7a3d26e8597f8f0ecd7dc1 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -83,8 +83,8 @@ app.user_options['worker'].add(worker_args) app.steps['worker'].add(WorkerArgs) -@app.task(bind=InventoryTask) -def snmp_refresh_interfaces(self, hostname, community): +@app.task() +def snmp_refresh_interfaces(hostname, community): task_logger = logging.getLogger(constants.TASK_LOGGER_NAME) task_logger.debug( '>>> snmp_refresh_interfaces(%r, %r)' % (hostname, community)) @@ -100,8 +100,8 @@ def snmp_refresh_interfaces(self, hostname, community): '<<< snmp_refresh_interfaces(%r, %r)' % (hostname, community)) -@app.task(bind=InventoryTask) -def netconf_refresh_config(self, hostname): +@app.task() +def netconf_refresh_config(hostname): task_logger = logging.getLogger(constants.TASK_LOGGER_NAME) task_logger.debug('>>> netconf_refresh_config(%r)' % hostname)