我正在尝试使用 nextflow 从我的 python 脚本中获得一些并发性,因此我的一些数据流不使用传统的 nextflow 理想。
在我的第一个过程中,我通过调用 python 脚本来创建文件,在我的第二个过程中,我想使用这些创建的文件
我创建了一个新通道来监视创建文件的路径,但似乎什么也没发生。我用 .fromPath 方法进行了测试,我的过程是成功的,所以我不确定出了什么问题?
mutFiles = Channel.watchPath(launchDir + '/output/mutFiles/*.mutfile')
process structurePrediction{
input:
file mutFiles
output:
stdout results
"""
test.py ${mutFiles}
"""
}