diff options
| author | Matthias Schiffer <mschiffer@universe-factory.net> | 2021-06-21 21:18:21 +0200 |
|---|---|---|
| committer | Matthias Schiffer <mschiffer@universe-factory.net> | 2021-06-21 21:20:17 +0200 |
| commit | 02551a89625cb9d70e66802ebed86766262cb59f (patch) | |
| tree | bc15bf3fc8f3daff5846ce59d240e13b3d1def30 /src/runner/runc.rs | |
| parent | f855b9013e6d4c7cf1cf6eb6c03884593decce3b (diff) | |
| download | rebel-02551a89625cb9d70e66802ebed86766262cb59f.tar rebel-02551a89625cb9d70e66802ebed86766262cb59f.zip | |
executor: calculate input hash
Diffstat (limited to 'src/runner/runc.rs')
| -rw-r--r-- | src/runner/runc.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/runner/runc.rs b/src/runner/runc.rs index 9725d92..f4016e3 100644 --- a/src/runner/runc.rs +++ b/src/runner/runc.rs @@ -14,7 +14,7 @@ use crate::util::ipc::CheckDisconnect; #[derive(Debug, Deserialize, Serialize)] struct Request( - TaskRef, + TaskID, TaskDef, ipc::IpcSender<Result<OutputHash, run::Error>>, ); @@ -106,8 +106,8 @@ impl RuncRunner { } impl super::Runner for RuncRunner { - fn run(&self, tasks: &TaskMap, task: &TaskRef) -> super::Result<OutputHash> { - let task_def = tasks.get(task).expect("Invalid TaskRef"); + fn run(&self, tasks: &TaskMap, task: &TaskID) -> super::Result<OutputHash> { + let task_def = tasks.get(task).expect("Invalid TaskID"); let (reply_tx, reply_rx) = ipc::channel().expect("IPC channel creation failed"); self.channel |