diff --git a/inventory_provider/routes/testing.py b/inventory_provider/routes/testing.py index 5ab0fb0ed64365b8d1c2efebb0dd64cd8ae801ae..5362f4a9fe7737a850d8f1ca3d594b8c91c90a55 100644 --- a/inventory_provider/routes/testing.py +++ b/inventory_provider/routes/testing.py @@ -2,7 +2,7 @@ import collections import json import re -from flask import Blueprint, Response, current_app, jsonify +from flask import Blueprint, Response, jsonify from lxml import etree from inventory_provider import juniper diff --git a/inventory_provider/tasks/config.py b/inventory_provider/tasks/config.py index 9e59a19335b81715406ef31c9acec14e81158909..846a2c2134d31ae1ab635fa277a95fe92606b57e 100644 --- a/inventory_provider/tasks/config.py +++ b/inventory_provider/tasks/config.py @@ -1,3 +1,4 @@ +import json from os import getenv broker_url = getenv( @@ -6,4 +7,13 @@ broker_url = getenv( result_backend = getenv( 'CELERY_BROKER_URL', default='redis://test-dashboard02.geant.org:6379/1') + +tmp_options = getenv( + 'BROKER_TRANSPORT_OPTIONS', + default='') +if tmp_options: + broker_transport_options = json.loads(tmp_options) +else: + broker_transport_options = {} + task_eager_propagates = True