concat_workflow_emissions

Collect an emission from multiple channels or processes into a collection.

github

Arguments

NameDescriptionType
channel_listCollection of channels that contain a named emission matching key.channels
keyName of the emitted channel from the processes in channel_list to collect.string

Example

// run a process, providing the required channels
module_1(opt, tags, ids)
module_2(opt, tags, ids, samples)
module_3(opt, tags, ids, targets)

// collect all of the emitted `ids`
channel_list = [module_1, module_2, module_3]

concat_workflow_emissions(channel_list, 'ids')
// [ "/path/to/work/dir/file_1.yaml",
//   "/path/to/work/dir/file_2.yaml",
//   "/path/to/work/dir/file_3.yaml" ]