pipeline - 如何将流程输出发送到 Nextflow 中的多个 channel ？

Question

我正在实现一个 Nextflow 工作流程，其中每个流程都可以提供不同流程下游可能需要的多个输出。

process multiple_outputs {
   input:
   tuple id, input from previous_process

   output:
   tuple id, input_for_a, input_for_b, input_for_a_b into downstream
}

Nextflow 文档指出 operator into can use multiple channels和 promotes channel duplication as a pattern .

但是这些选项似乎都不适用于 the process primitive和 multiple channel output is not documented :

• 模式found on this answer (语法错误):

  output:
  tuple id, input_for_a, input_for_b, input_for_a_b into { downstream_a; downstream_b }
  // nor these variants:
  //
  // `into { downstream_a, downstream_b }`
  // `into downstream_a, downstream_b`
  // `into tuple a, b`
  

• 将输出重复到重复的 channel (一个 channel 为空):

  output:
  tuple id, input_for_a, input_for_a_b into downstream_a
  tuple id, input_for_b, input_for_a_b into downstream_b
  // runs, but cannot find the file in one of the channels
  

在多个 channel 中使用输出的正确方法是什么？

Answer 1

输出声明应该是:

output:
tuple id, input_for_a, input_for_b, input_for_a_b into(downstream_a, downstream_b)

或者，您可能需要考虑使用不再有单 channel 使用要求的 DLS2。了解更多相关信息here .