On splitte services et parsers (qui ne sont utilisés que par civet.event)
This commit is contained in:
parent
f24e463da5
commit
06095f5580
7 changed files with 96 additions and 46 deletions
|
@ -37,7 +37,7 @@ logger = clogger.CLogger("trigger", "event", trigger_config.log_level, trigger_c
|
|||
services = []
|
||||
for config_service in trigger_config.all_services:
|
||||
try:
|
||||
services.append(importlib.import_module("gestion.trigger.services.%s" % (config_service,)))
|
||||
services.append(importlib.import_module("gestion.trigger.parsers.%s" % (config_service,)))
|
||||
except Exception as e:
|
||||
logger.critical("Fatal : import of %s failed, see following traceback. %s", config_service, traceback.format_exc())
|
||||
|
||||
|
@ -175,7 +175,7 @@ def event(body=()):
|
|||
#
|
||||
#In [16]: b
|
||||
#Out[16]: [('7', 3), (5, 6), ('lol', 'lal'), (3, 'lol')]
|
||||
functions = list(set([function for function in itertools.chain(*[TriggerFactory.get_parser(key) for key in diff])]))
|
||||
functions = list(set([function for function in itertools.chain(*[TriggerFactory.get_parser(key) for key in diff]) if function is not None]))
|
||||
msg_to_send = [function(body, diff) for function in functions]
|
||||
|
||||
for msg in msg_to_send:
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue