summaryrefslogtreecommitdiffstats
path: root/src/executor.rs
diff options
context:
space:
mode:
authorMatthias Schiffer <mschiffer@universe-factory.net>2021-07-24 13:30:30 +0200
committerMatthias Schiffer <mschiffer@universe-factory.net>2021-07-24 14:16:54 +0200
commitbab15c9e650db77229e7d4d2181d30dfe119d025 (patch)
tree9a0e9698d65cc4a53def60bdb2d78ce2232c6a43 /src/executor.rs
parent9ba27c046e57a3fa55643123147318db117b5dba (diff)
downloadrebel-bab15c9e650db77229e7d4d2181d30dfe119d025.tar
rebel-bab15c9e650db77229e7d4d2181d30dfe119d025.zip
Replace TaskMap struct with type alias
Diffstat (limited to 'src/executor.rs')
-rw-r--r--src/executor.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/executor.rs b/src/executor.rs
index fc12725..0a12d73 100644
--- a/src/executor.rs
+++ b/src/executor.rs
@@ -55,7 +55,7 @@ impl<'a> Executor<'a> {
};
for task in taskset {
- let task_def = tasks.get(&task).expect("Invalid TaskRef");
+ let task_def = tasks.get(&task.id).expect("Invalid TaskRef");
if task_def.depends.is_empty() {
exc.tasks_runnable.push(task);
} else {
@@ -77,7 +77,7 @@ impl<'a> Executor<'a> {
}
fn deps_satisfied(&self, task: &TaskRef) -> bool {
- let task_def = self.tasks.get(task).expect("Invalid TaskRef");
+ let task_def = self.tasks.get(&task.id).expect("Invalid TaskRef");
task_def
.depends
@@ -102,7 +102,7 @@ impl<'a> Executor<'a> {
fn run_one(&mut self, runner: &impl runner::Runner) -> runner::Result<()> {
let task_ref = self.tasks_runnable.pop().expect("No runnable tasks left");
- let task_def = self.tasks.get(&task_ref).expect("Invalid TaskRef");
+ let task_def = self.tasks.get(&task_ref.id).expect("Invalid TaskRef");
let task_deps = self.task_deps(&task_def);
let task = Task {