Skip to content

Commit dc89a0c

Browse files
committed
Cache fix
1 parent 4781d01 commit dc89a0c

1 file changed

Lines changed: 14 additions & 2 deletions

File tree

task-maker-cache/src/lib.rs

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -180,13 +180,25 @@ impl Cache {
180180
Some(outputs) if entry.is_compatible(group) => {
181181
let mut results = Vec::new();
182182
for (exec, item) in group.executions.iter().zip(entry.items.iter()) {
183+
let stdout = item.stdout.as_ref().and_then(|key| {
184+
file_store
185+
.get(key)
186+
.and_then(|handle| std::fs::read(handle.path()).ok())
187+
});
188+
189+
let stderr = item.stderr.as_ref().and_then(|key| {
190+
file_store
191+
.get(key)
192+
.and_then(|handle| std::fs::read(handle.path()).ok())
193+
});
194+
183195
results.push(ExecutionResult {
184196
status: exec.status(&item.result.status, &item.result.resources),
185197
was_killed: item.result.was_killed,
186198
was_cached: true,
187199
resources: item.result.resources.clone(),
188-
stdout: item.result.stdout.clone(),
189-
stderr: item.result.stderr.clone(),
200+
stdout,
201+
stderr,
190202
});
191203
}
192204
return CacheResult::Hit {

0 commit comments

Comments
 (0)