Skip to content
Snippets Groups Projects
Commit b9e9c725 authored by Erik Reid's avatar Erik Reid
Browse files

pep8

parent 5ff8c113
Branches
Tags
No related merge requests found
...@@ -2,6 +2,7 @@ from brian_polling_manager import sensu ...@@ -2,6 +2,7 @@ from brian_polling_manager import sensu
_CHECK_PREFIX = 'eumetmc' _CHECK_PREFIX = 'eumetmc'
def load_eumetsat_multicast_checks(sensu_params): def load_eumetsat_multicast_checks(sensu_params):
def _is_eumetsat_multicast_check(check): def _is_eumetsat_multicast_check(check):
name = check['metadata']['name'] name = check['metadata']['name']
......
...@@ -117,6 +117,7 @@ MULTICAST_SUBSCRIPTION_LIST_SCHEMA = { ...@@ -117,6 +117,7 @@ MULTICAST_SUBSCRIPTION_LIST_SCHEMA = {
'items': {'$ref': '#/definitions/subscription'} 'items': {'$ref': '#/definitions/subscription'}
} }
def _pick_one(haystack): def _pick_one(haystack):
if not isinstance(haystack, (list, tuple, set)): if not isinstance(haystack, (list, tuple, set)):
haystack = [haystack] haystack = [haystack]
......
...@@ -88,7 +88,7 @@ def refresh(config, force=False): ...@@ -88,7 +88,7 @@ def refresh(config, force=False):
config['inventory']) config['inventory'])
state.eumetsat_multicast \ state.eumetsat_multicast \
= inventory.load_eumetsat_multicast_subscriptions( = inventory.load_eumetsat_multicast_subscriptions(
config['inventory']) config['inventory'])
result = { result = {
'interfaces': interfaces.refresh(config['sensu'], state.interfaces), 'interfaces': interfaces.refresh(config['sensu'], state.interfaces),
'gws_direct': gws_direct.refresh(config['sensu'], state.gws_direct), 'gws_direct': gws_direct.refresh(config['sensu'], state.gws_direct),
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment