diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 67290892e26dff1fa8a70caee967b6cfc617bbda..643adc48667bff40fb594f99547f81b7a5404c7a 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -27,31 +27,31 @@ class InventoryTask(Task): pass @staticmethod - def save_key(hostname, key, data): + def save_key(hostname, key, value): r = redis.StrictRedis( host=InventoryTask.config["redis"]["hostname"], port=InventoryTask.config["redis"]["port"]) r.hset( name=hostname, key=key, - value=json.dumps(data)) + value=value) InventoryTask.logger.debug( "saved %s, key %s" % (hostname, key)) return "OK" @staticmethod - def save_key_json(hostname, key, data): + def save_key_json(hostname, key, data_obj): InventoryTask.save_key( hostname, key, - json.dumps(data)) + json.dumps(data_obj)) @staticmethod - def save_key_etree(hostname, key, data): + def save_key_etree(hostname, key, xml_doc): InventoryTask.save_key( hostname, key, - etree.tostring(data, encoding='unicode')) + etree.tostring(xml_doc, encoding='unicode')) class WorkerArgs(bootsteps.Step):