是否有一种干净的方法可以在单个节点上运行NextFlow（基于DSL2）的子工作流？

Question

我在子工作流中定义了一个管道：

workflow pipeline{
    main:
            task1()
            task2(task1.out)
            ...

}

由主工作流来调用不同输入：

workflow{
    params.in = "$baseDir/input"

    input_ch = Channel.fromPath(params.in + "/*.*")
    main:
            pipeline(input_ch)

}

它易于添加标签以处理以定义其资源。我想做的就是将这样的标签添加到我的（整个）子Workflow中。他们的标签应该迫使子处理程序执行为一个单个过程（这意味着它不会调用所有进程的新slurm调用，而仅调用每个进程的呼叫），例如：

                - pipeline for input 1 on node 1 as one slurmjob
                
                - pipeline for input 2 on node 2 as one slurmjob
- main:                                                                 - collect all the outputs
                        ...

                - pipeline for input n on node n as one slurmjob

我是通过在nextflow内部调用nextflow来做到的：

process nextflowofnextflows {
    label 'use_whatever_is_needed'


    input:
    file input1

    output:
    path("$out/*.*", emit: output)

    
    script:
    """
    nextflow run pipline.nf --in=${input1}

    """
}

...-但这是超级不洁的，我想以一种干净的方式对其进行处理。

实现所描述行为的最佳实践是什么？

最好，t。