merge_process_emissions

Iteratively merges output channels of a process into a single channel of maps.

github

Arguments

NameDescriptionType
processOutput of a process that emits output named in keys.channel
keysCollection of strings that list which emitted channels in process are merged.strings

Output value

A channel that emits the values of process’s keys in a map.

Example

// run a process, providing the required channels
module_name(opt, tags, ids)

// make a channel of outputs from the module
merge_process_emissions(module_name, ['opt', 'output_file'])

// { "opt": {
//      "ids": ["A", "B", "C"],
//      "secret": "foo-bar"},
//   "output_file": "/path/to/work/dir/out.file" }