Skip to content

Commit 3ca1ca9

Browse files
pditommasoclaude
andcommitted
refactor: use PipelineSpec for pipeline metadata in CreateRunRequest
Move workDir, workflowId, workflowUrl into PipelineSpec nested object, keeping name at the top level of CreateRunRequest. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> Signed-off-by: Paolo Di Tommaso <paolo.ditommaso@gmail.com>
1 parent 11e3400 commit 3ca1ca9

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

plugins/nf-seqera/src/main/io/seqera/executor/SeqeraExecutor.groovy

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,9 @@ import io.seqera.config.SeqeraConfig
2222
import io.seqera.config.ExecutorOpts
2323
import io.seqera.util.SchemaMapperUtil
2424
import io.seqera.sched.api.schema.v1a1.CreateRunRequest
25+
import io.seqera.sched.api.schema.v1a1.PipelineSpec
2526
import io.seqera.sched.api.schema.v1a1.PredictionModel
27+
2628
import io.seqera.sched.client.SchedClient
2729
import io.seqera.sched.api.schema.v1a1.TerminateRunRequest
2830
import io.seqera.sched.client.SchedClientConfig
@@ -108,11 +110,13 @@ class SeqeraExecutor extends Executor implements ExtensionPoint {
108110
final request = new CreateRunRequest()
109111
.region(seqeraConfig.region)
110112
.name(session.runName)
113+
.pipeline(new PipelineSpec()
114+
.workDir(session.workDir?.toUriString())
115+
.workflowId(workflowId)
116+
.workflowUrl(workflowUrl))
111117
.machineRequirement(SchemaMapperUtil.toMachineRequirement(seqeraConfig.machineRequirement))
112118
.labels(labels.entries)
113119
.workspaceId(PlatformHelper.getWorkspaceId(towerConfig, SysEnv.get()) as Long)
114-
.workflowId(workflowId)
115-
.workflowUrl(workflowUrl)
116120
.predictionModel(predictionModel)
117121
log.debug "[SEQERA] Creating run: ${request}"
118122
final response = client.createRun(request)

0 commit comments

Comments
 (0)