diff --git a/brian_polling_manager/eumetsat_multicast.py b/brian_polling_manager/eumetsat_multicast.py index d4ed0c5aba4d6faf42fbf6c26680171f3746d0fa..4bfdf497f747c0167b69ba81622ea2d6cd4c9ea8 100644 --- a/brian_polling_manager/eumetsat_multicast.py +++ b/brian_polling_manager/eumetsat_multicast.py @@ -2,6 +2,7 @@ from brian_polling_manager import sensu _CHECK_PREFIX = 'eumetmc' + def load_eumetsat_multicast_checks(sensu_params): def _is_eumetsat_multicast_check(check): name = check['metadata']['name'] diff --git a/brian_polling_manager/inventory.py b/brian_polling_manager/inventory.py index 72043739cc1823b5e4496ce17a43f6c7def912db..4b4594d22ce9556793c55a9b18be992c70b1495e 100644 --- a/brian_polling_manager/inventory.py +++ b/brian_polling_manager/inventory.py @@ -117,6 +117,7 @@ MULTICAST_SUBSCRIPTION_LIST_SCHEMA = { 'items': {'$ref': '#/definitions/subscription'} } + def _pick_one(haystack): if not isinstance(haystack, (list, tuple, set)): haystack = [haystack] diff --git a/brian_polling_manager/main.py b/brian_polling_manager/main.py index ab64d50a13330bbd5137e02c3c43fd42e96cbc19..90ba9f94c8841906efaa2f50bab5a7f4c518781e 100644 --- a/brian_polling_manager/main.py +++ b/brian_polling_manager/main.py @@ -88,7 +88,7 @@ def refresh(config, force=False): config['inventory']) state.eumetsat_multicast \ = inventory.load_eumetsat_multicast_subscriptions( - config['inventory']) + config['inventory']) result = { 'interfaces': interfaces.refresh(config['sensu'], state.interfaces), 'gws_direct': gws_direct.refresh(config['sensu'], state.gws_direct),