单个Nextflow进程中能否实现输出反馈至输入的逻辑？

核心报错来自两个问题：

• 反馈通道首次运行时没有初始值，空通道状态下Nextflow会直接将DataflowQueue通道对象本身作为参数传入脚本，Python无法识别该对象，因此抛出NameError。
• 两个输入通道没有做配对关联，无法保证输入数值和反馈值的顺序一一对应，无法实现连续累加逻辑。

修改后的完整脚本如下：

// 声明反馈通道，先注入初始值0，解决首次运行无值的问题
feedback_ch = Channel.create()
initial_val_ch = Channel.of(0)
input_ch = initial_val_ch.mix(feedback_ch)

// 待累加的输入数值通道
num_ch = Channel.of(1,2,3)

process test {
    echo true 

    input:
        val cur_num from num_ch
        val feedback_val from input_ch
 
    output:
        stdout trim().toInteger() into feedback_ch

    shell:
    '''
    #!/usr/bin/python3
    new_val = !{cur_num} + !{feedback_val}
    print(new_val)
    '''
}

// 打印最终输出结果
feedback_ch.view { "累加结果: $it" }

• 新增初始值通道initial_val_ch，第一次运行时反馈值取0，彻底解决空通道传对象的问题
• 输入数值通道和反馈通道自动顺序配对，保证每次计算都能取到上一轮的输出值
• 输出时对stdout做去除空白、转整数处理，避免后续计算出现类型错误

运行后会依次输出符合预期的累加结果：

累加结果: 1
累加结果: 3
累加结果: 6

内容的提问来源于stack exchange，提问作者TheCodeNovice