e.g. 7f08cdb62621f878c6eca74154e502ff currently fails to parse
The if module['type'] == 'loop' test in _parse_pipe should then check for module['conf']['embed'] == None, and then ensure the loop can emit/assign its input stream. Probably best to create a pipe_identity operator that simply returns whatever it is passed and embed that as a default module.
e.g. 7f08cdb62621f878c6eca74154e502ff currently fails to parse
The
if module['type'] == 'loop'
test in_parse_pipe
should then check formodule['conf']['embed'] == None
, and then ensure the loop can emit/assign its input stream. Probably best to create apipe_identity
operator that simply returns whatever it is passed and embed that as a default module.