diff --git a/inventory_provider/tasks/app.py b/inventory_provider/tasks/app.py index 15a42327ee55a1058b513bb32f52a5f388069efa..a4a68d2fccb847d18844c556bd0a01c0b6136788 100644 --- a/inventory_provider/tasks/app.py +++ b/inventory_provider/tasks/app.py @@ -1,4 +1,13 @@ +import logging +import sys +from inventory_provider import constants from celery import Celery +logging.basicConfig(stream=sys.stderr, level=logging.WARNING) +logging.getLogger(constants.SNMP_LOGGER_NAME).setLevel(logging.DEBUG) +logging.getLogger(constants.TASK_LOGGER_NAME).setLevel(logging.DEBUG) +logging.getLogger(constants.JUNIPER_LOGGER_NAME).setLevel(logging.DEBUG) +logging.getLogger(constants.DATABASE_LOGGER_NAME).setLevel(logging.DEBUG) + app = Celery("app") app.config_from_object("inventory_provider.tasks.config") diff --git a/inventory_provider/tasks/worker.py b/inventory_provider/tasks/worker.py index 643adc48667bff40fb594f99547f81b7a5404c7a..3458f9e298b8889e667aa1eb41503bb38039b4aa 100644 --- a/inventory_provider/tasks/worker.py +++ b/inventory_provider/tasks/worker.py @@ -28,6 +28,8 @@ class InventoryTask(Task): @staticmethod def save_key(hostname, key, value): + assert isinstance(value, str), \ + "sanity failure: expected string data as value" r = redis.StrictRedis( host=InventoryTask.config["redis"]["hostname"], port=InventoryTask.config["redis"]["port"])