concat_workflow_emissions
Collect an emission from multiple channels or processes into a collection.
githubArguments
Name | Description | Type |
---|---|---|
channel_list | Collection of channels that contain a named emission matching key . | channels |
key | Name 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" ]