Skip to content

Commit 669afd5

Browse files
committed
Minor changes [ci skip]
Signed-off-by: Paolo Di Tommaso <[email protected]>
1 parent b5e8c46 commit 669afd5

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

modules/nextflow/src/main/groovy/nextflow/data/cid/CidObserver.groovy

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,11 +85,14 @@ class CidObserver implements TraceObserver {
8585
protected void storeTaskOutput(TaskRun task, Path path) {
8686
final attrs = readAttributes(path)
8787
final rel = task.workDir.relativize(path).toString()
88-
final key = "${task.hash}/${rel}/.data.json"
88+
final cid = "${task.hash}/${rel}"
89+
final uri = "cid://${cid}"
90+
final key = "${cid}/.data.json"
8991
final hash = CacheHelper.hasher(path).hash().toString()
9092
final value = new TaskOutput(
9193
DataType.Output,
92-
"cid://$key",
94+
uri,
95+
path.toUriString(),
9396
hash,
9497
attrs.size(),
9598
attrs.creationTime().toMillis(),

modules/nextflow/src/main/groovy/nextflow/data/cid/model/TaskOutput.groovy

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ import groovy.transform.CompileStatic
2929
class TaskOutput {
3030
DataType type
3131
String uri
32+
String realPath
3233
String hash
3334
long size
3435
long createdAt

0 commit comments

Comments
 (0)