Add labels support to Seqera executor for cost tracking

Add configurable labels that are propagated to AWS resources (ECS tasks,
capacity providers, EC2 instances) for cost tracking and resource organization.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
Signed-off-by: Paolo Di Tommaso <paolo.ditommaso@gmail.com>

Author: pditommaso

plugins/nf-seqera/src/main/io/seqera/config/SeqeraConfig.groovy

@@ -67,6 +67,13 @@ class SeqeraConfig implements ConfigScope {
     """)
     final MachineRequirementOpts machineRequirement
 
+    @ConfigOption
+    @Description("""
+        Custom labels to apply to AWS resources for cost tracking and resource organization.
+        Labels are propagated to ECS tasks, capacity providers, and EC2 instances.
+    """)
+    final Map<String, String> labels
+
     /* required by config scope -- do not remove */
     SeqeraConfig() {}
 
@@ -83,6 +90,8 @@ class SeqeraConfig implements ConfigScope {
             : Duration.of('1 sec')
         // machine requirement settings
         this.machineRequirement = new MachineRequirementOpts(opts.machineRequirement as Map ?: Map.of())
+        // labels for cost tracking
+        this.labels = opts.labels as Map<String, String>
     }
 
     RetryOpts retryOpts() {
@@ -108,4 +117,8 @@ class SeqeraConfig implements ConfigScope {
     MachineRequirementOpts getMachineRequirement() {
         return machineRequirement
     }
+
+    Map<String, String> getLabels() {
+        return labels
+    }
 }

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

@@ -85,8 +85,9 @@ class SeqeraExecutor extends Executor implements ExtensionPoint {
 
     protected void createSession() {
         final machineReq = MapperUtil.toMachineRequirement(seqeraConfig.machineRequirement)
-        log.debug "[SEQERA] Creating session for workflow in region: ${seqeraConfig.region}, runName: ${session.runName}, machineRequirement: ${machineReq}"
-        final response = client.createSession(seqeraConfig.region, session.runName, machineReq)
+        final labels = seqeraConfig.labels
+        log.debug "[SEQERA] Creating session for workflow in region: ${seqeraConfig.region}, runName: ${session.runName}, machineRequirement: ${machineReq}, labels: ${labels}"
+        final response = client.createSession(seqeraConfig.region, session.runName, machineReq, labels)
         this.sessionId = response.getSessionId()
         log.debug "[SEQERA] Session created id: ${sessionId}"
         // Initialize and start batch submitter with error callback to abort session on fatal errors

plugins/nf-seqera/src/test/io/seqera/config/SeqeraConfigTest.groovy

@@ -127,4 +127,40 @@ class SeqeraConfigTest extends Specification {
         config.machineRequirement.provisioning == 'spot'
     }
 
+    def 'should create config with labels' () {
+        when:
+        def config = new SeqeraConfig([
+            endpoint: 'https://sched.example.com',
+            labels: [
+                project: 'genomics',
+                team: 'research',
+                costCenter: 'CC-1234'
+            ]
+        ])
+
+        then:
+        config.labels == [project: 'genomics', team: 'research', costCenter: 'CC-1234']
+    }
+
+    def 'should handle null labels' () {
+        when:
+        def config = new SeqeraConfig([
+            endpoint: 'https://sched.example.com'
+        ])
+
+        then:
+        config.labels == null
+    }
+
+    def 'should handle empty labels' () {
+        when:
+        def config = new SeqeraConfig([
+            endpoint: 'https://sched.example.com',
+            labels: [:]
+        ])
+
+        then:
+        config.labels == [:]
+    }
+
 }