Nextflow启用resume时publishDir唯一目录变为null如何解决？

架构老林

2026-6-29

解决Nextflow resume时publishDir的task.hash为null问题

问题原因

当使用resume参数重启工作流时，Nextflow会复用已缓存的任务结果，此时task.hash变量无法被正确解析（返回null），导致发布目录名称异常。这是因为task.hash是任务首次执行时生成的临时属性，从缓存恢复任务时该属性未被初始化。

解决方案

可以替换为以下几种稳定的唯一标识方案，确保无论是否使用resume，都能生成唯一的发布目录：

方案1：使用`task.id`（推荐）

task.id是Nextflow为每个任务分配的全局唯一标识符，无论任务是首次执行还是从缓存恢复，该值都保持不变。修改后的配置如下：

publishDir = [
    path: { "${params.outdir}/${task.process.tokenize(':')[-1].tokenize('_')[0].toLowerCase()}/${task.id}" },
    mode: params.publish_dir_mode,
    saveAs: { filename -> filename.equals('versions.yml') ? null : filename }
]

方案2：使用输入文件的哈希值

如果每个任务对应单个输入文件，可以直接用输入文件的哈希值作为目录名，目录与输入文件强绑定，逻辑更直观（假设输入变量为input_file）：

publishDir = [
    path: { "${params.outdir}/${task.process.tokenize(':')[-1].tokenize('_')[0].toLowerCase()}/${input_file.hash}" },
    mode: params.publish_dir_mode,
    saveAs: { filename -> filename.equals('versions.yml') ? null : filename }
]

方案3：使用工作目录名称

任务工作目录的名称本质就是任务的哈希值，和你最初使用task.hash的效果完全一致，且在resume场景下能稳定获取：

publishDir = [
    path: { "${params.outdir}/${task.process.tokenize(':')[-1].tokenize('_')[0].toLowerCase()}/${task.workDir.name}" },
    mode: params.publish_dir_mode,
    saveAs: { filename -> filename.equals('versions.yml') ? null : filename }
]