Nextflow -resume失效求助:bwa_map流程重复执行问题排查
问题分析与排查方案
1. when条件的核心问题
- 原when条件如果包含动态变量(比如
new Date()、每次运行变化的params参数、临时路径),Nextflow会判定流程的执行条件发生改变,导致-resume时跳过缓存、重新执行。 - 删除when后无输出,说明原条件是用来过滤输入通道数据的:只有满足条件的样本才会触发bwa_map,删条件后通道可能无符合要求的输入(比如上游流程没产出对应数据、通道为空),因此流程未执行。
2. cache='lenient'无效的原因
cache='lenient'仅会忽略流程参数的非关键变化,但无法解决以下导致缓存失效的场景:
- 输入文件的元数据(修改时间、大小)发生变化;
- bwa_map的脚本内容(命令、注释)或依赖环境(容器版本、环境变量)改动;
- 输入通道的数据流指纹变化(比如样本顺序、文件名修改)。
3. 具体排查步骤
- 恢复原when条件,排查缓存失效原因:
用nextflow log查看两次运行的缓存差异,重点看reason字段,明确是输入、脚本还是参数导致的缓存失效:nextflow log -f process,hash,reason <你的运行ID/名称> - 验证when条件的静态性:
确保when里的判断逻辑只依赖静态值(比如输入文件的属性、固定配置参数),避免动态生成的内容。可以在条件里加日志输出,确认触发逻辑:process bwa_map { when: def meetsCondition = (sample_id in params.target_samples) println "[DEBUG] Sample ${sample_id} - bwa_map trigger: ${meetsCondition}" meetsCondition // 其他流程配置... } - 检查输入通道有效性:
删除when后,在上游通道添加日志,确认是否有数据流入bwa_map:upstream_channel.view { println "[DEBUG] Sending data to bwa_map: ${it}" } | bwa_map - 确认输入文件稳定性:
检查bwa_map的输入文件(参考基因组、测序reads)是否被修改过,避免使用指向动态文件的软链接。
内容的提问来源于stack exchange,提问作者Nguyễn Tiến Dũng
相关产品推荐
相关产品推荐

