在Nextflow新管道中调用其他Nextflow管道的最佳方法

作为NextFlow新手，整合多个独立管道的核心是复用已有的工作流定义，以下是几种实用且推荐的方案：

1. 直接用 include 指令导入外部管道脚本 #

这是最简单的方式，适合导入单文件的完整管道。假设你有一个rna_pipeline.nf，里面已经定义了完整的workflow rna_analysis，主管道中可以直接导入并调用：

// 主管道 main.nf
// 导入外部管道的工作流
include { rna_analysis } from './rna_pipeline.nf'

workflow {
    // 准备输入通道
    raw_reads = channel.fromPath('./raw_data/*.fastq.gz')
    // 直接调用导入的完整管道
    rna_analysis(raw_reads)
}

如果外部管道依赖参数，主管道可以通过全局params传递，或者在调用时覆盖：

// 覆盖子管道的参数
rna_analysis.withParams({
    ref_genome = './ref/hg38.fa'
    threads = 8
})(raw_reads)

2. 用NextFlow Modules规范复用（推荐） #

如果你的外部管道是一个独立的模块（带自己的main.nf和nextflow.config），用模块导入更易维护。比如子管道结构：

variant_calling_pipeline/
├── main.nf       # 包含workflow variant_call
└── nextflow.config  # 子管道的资源、参数配置

主管道中导入方式：

// 主管道 main.nf
include { variant_call } from './variant_calling_pipeline'

workflow {
    bam_files = channel.fromPath('./aligned/*.bam')
    variant_call(bam_files)

    // 可以针对性修改子管道中某个流程的配置
    variant_call.withName('GATK_HAPLOTYPECALLER') {
        memory = '64.GB'
        executor = 'slurm'
    }
}

模块方式会自动加载子管道的配置文件，若配置冲突，主管道的配置优先级更高。

3. 封装子工作流做适配 #

如果需要在调用外部管道前后添加自定义逻辑（比如输入预处理、输出过滤），可以封装成子工作流：

// 主管道 main.nf
include { chip_seq_analysis } from './chip_seq_pipeline.nf'

workflow integrated_pipeline {
    take:
        raw_chip_reads
    main:
        // 自定义预处理流程
        filtered_reads = filter_low_quality(raw_chip_reads)
        // 调用外部完整管道
        chip_seq_analysis(filtered_reads)
    emit:
        chip_seq_analysis.out.peaks
}

// 自定义预处理流程
process filter_low_quality {
    input:
        path reads
    output:
        path 'filtered_*.fastq.gz' into filtered_reads
    script:
        """
        fastp -i ${reads} -o filtered_${reads} -q 20
        """
}

核心注意事项 #

• 通道匹配：确保主管道输出的通道类型（文件/值/队列）和子管道的输入通道类型一致，避免通道不兼容错误。
• 参数隔离：如果不想污染全局params，可以用withParams为子管道单独设置参数。
• 版本控制：若外部管道是本地Git仓库，可通过include指定具体分支或标签来固定版本。

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