From 0998b86d3a2f18a8d3984692d424f26e0bcf5bf5 Mon Sep 17 00:00:00 2001 From: Don Freed Date: Tue, 10 Dec 2024 11:51:03 -0800 Subject: [PATCH] Minor fixes --- sentieon_cli/dag.py | 2 +- sentieon_cli/dnascope_longread.py | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/sentieon_cli/dag.py b/sentieon_cli/dag.py index 37f1328..3fad4be 100644 --- a/sentieon_cli/dag.py +++ b/sentieon_cli/dag.py @@ -35,7 +35,7 @@ def add_job(self, job: Job, dependencies: Optional[Set[Job]] = None): ) if isinstance(dependencies, set) and len(dependencies) > 0: - self.waiting_jobs[job] = dependencies + self.waiting_jobs[job] = dependencies.copy() for dependency in dependencies: downstream = self.planned_jobs.setdefault(dependency, []) downstream.append(job) diff --git a/sentieon_cli/dnascope_longread.py b/sentieon_cli/dnascope_longread.py index 2db244e..0349334 100644 --- a/sentieon_cli/dnascope_longread.py +++ b/sentieon_cli/dnascope_longread.py @@ -926,10 +926,12 @@ def dnascope_longread( realign_jobs: Set[Job] = set() if align: sample_input, realign_jobs = align_inputs(**locals()) - map(dag.add_job, realign_jobs) + for job in realign_jobs: + dag.add_job(job) aligned_fastq, align_jobs = align_fastq(**locals()) sample_input.extend(aligned_fastq) - map(dag.add_job, align_jobs) + for job in align_jobs: + dag.add_job(job) if not skip_mosdepth: mosdpeth_jobs = mosdepth(**locals())