diff options
Diffstat (limited to 'crates/runner/src/task.rs')
| -rw-r--r-- | crates/runner/src/task.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/crates/runner/src/task.rs b/crates/runner/src/task.rs index 19a7484..b716b82 100644 --- a/crates/runner/src/task.rs +++ b/crates/runner/src/task.rs @@ -76,7 +76,7 @@ fn input_hash(task: &Task) -> InputHash { fn init_task(input_hash: &InputHash, task: &Task) -> Result<fs::Mount> { // Remove metadata first to ensure task invalidation - fs::ensure_removed(&paths::task_cache_filename(input_hash))?; + fs::ensure_removed(paths::task_cache_filename(input_hash))?; let task_state_dir = paths::task_state_dir(input_hash); @@ -250,11 +250,11 @@ fn init_task_rootfs(input_hash: &InputHash, task: &Task) -> Result<Stack<fs::Mou fn cleanup_task(input_hash: &InputHash) -> Result<()> { let task_tmp_dir = paths::task_tmp_dir(input_hash); - fs::ensure_removed(&task_tmp_dir).context("Failed to remove task tmp dir")?; + fs::ensure_removed(task_tmp_dir).context("Failed to remove task tmp dir")?; let task_state_dir = paths::task_state_dir(input_hash); let task_work_dir = paths::join(&[&task_state_dir, paths::TASK_STATE_WORK_SUBDIR]); - fs::ensure_removed(&task_work_dir).context("Failed to remove overlayfs workdir")?; + fs::ensure_removed(task_work_dir).context("Failed to remove overlayfs workdir")?; Ok(()) } @@ -445,7 +445,7 @@ fn run_task(input_hash: &InputHash, task: &Task, jobserver: &mut Jobserver) -> R .context("Failed to unset O_CLOEXEC on jobserver pipe")?; let err = Command::new("sh") - .args(&["-ex", &paths::join(&[paths::TASK_TASKDIR, paths::TASK_RUN])]) + .args(["-ex", &paths::join(&[paths::TASK_TASKDIR, paths::TASK_RUN])]) .stdin(Stdio::null()) .stdout(log_stdout) .stderr(log_stderr) @@ -556,7 +556,7 @@ fn load_cached(input_hash: &InputHash) -> Result<TaskOutput> { } fn save_cached(input_hash: &InputHash, output: &TaskOutput) -> Result<()> { - fs::mkdir(&paths::task_state_dir(input_hash))?; + fs::mkdir(paths::task_state_dir(input_hash))?; let tmp_filename = paths::task_cache_tmp_filename(input_hash); let filename = paths::task_cache_filename(input_hash); |