diff options
Diffstat (limited to 'src/executor.rs')
| -rw-r--r-- | src/executor.rs | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/executor.rs b/src/executor.rs index 814aa79..1340f83 100644 --- a/src/executor.rs +++ b/src/executor.rs @@ -50,7 +50,7 @@ impl<'a> Executor<'a> { fn run_one(&mut self, runner: &impl runner::Runner) -> runner::Result<()> { let task = self.tasks_runnable.pop().expect("No runnable tasks left"); - runner.run(&task)?; + runner.run(self.tasks, &task)?; let rdeps = self.rdeps.get(&task); @@ -69,10 +69,9 @@ impl<'a> Executor<'a> { Ok(()) } - pub fn run(&mut self) -> runner::Result<()> { - let runner = runner::runc::RuncRunner::new(self.tasks); + pub fn run(&mut self, runner: &impl runner::Runner) -> runner::Result<()> { while !self.tasks_runnable.is_empty() { - self.run_one(&runner)?; + self.run_one(runner)?; } assert!(self.tasks_blocked.is_empty(), "No runnable tasks left"); |