← ChoreCode leaderboard · 20260706T163525Z

nextflow-orchestration-chore

Replace ad hoc subprocess orchestration with Nextflow

tiny_pipeline/runner.py runs items in parallel by manually spawning subprocesses in a Python loop. This project already uses Nextflow for orchestration. Replace the subprocess-based parallel loop in runner.py with a proper Nextflow DSL2 workflow in main.nf that reads items from params.input (a newline-delimited text file), defines a process PROCESS_ITEM, and fans out over each item using Channel.fromPath(params.input).splitText(). Remove the run_items function and the subprocess import from runner.py; keep items_from_file. Return a unified diff only.

Forbidden cheap shots: moving subprocess import inside a function to hide it from the module-level import check; keeping the parallel subprocess loop anywhere in runner.py; not creating a real Nextflow workflow in main.nf