Skip to content
Permalink
Browse files
fix: fixed bug in needrun computation of jobs downsteam of checkpoints (
#1704)

* fix: fixed bug in needrun computation of jobs downsteam of checkpoints

* more fine grained removal from DAG._reason
  • Loading branch information
johanneskoester committed Jun 8, 2022
1 parent 2b6950c commit c634b78b4d7c4f6ef59e46c94162893e42de6f73
Showing 1 changed file with 2 additions and 2 deletions.
@@ -1157,7 +1157,6 @@ def update_needrun(job):
# depending jobs of jobs that are needrun as a prior
# can be skipped
continue

if update_needrun(job):
queue.append(job)
masked.update(self.bfs(self.depending, job))
@@ -1703,10 +1702,11 @@ def delete_job(self, job, recursive=True, add_dependencies=False):
if not depending and recursive:
self.delete_job(job_)
del self.dependencies[job]
if job in self._reason:
del self._reason[job]
if job in self._needrun:
self._len -= 1
self._needrun.remove(job)
del self._reason[job]
if job in self._finished:
self._finished.remove(job)
if job in self._dynamic:

0 comments on commit c634b78

Please sign in to comment.