feat: add optional platform and token_env fields to input samplesheet (SE-107)

Allow mixing runs from different Seqera Platform instances in a single
benchmark by adding two optional columns to the input CSV:

- platform:  Seqera Platform API URL override (falls back to --seqera_api_endpoint)
- token_env: env-var name holding the bearer token (falls back to TOWER_ACCESS_TOKEN)

Both fields are fully backward-compatible. The per-row overrides are
honoured in the benchmark report path (SeqeraApi.fetchRunData); the
tw CLI path (SEQERA_RUNS_DUMP) still uses global config.

Author: edmundmiller

assets/schema_input.json

@@ -30,6 +30,18 @@
                 "pattern": "^\\S+$",
                 "errorMessage": "Please provide a valid file path to your Seqera Platform logs.",
                 "meta": ["logs"]
+            },
+            "platform": {
+                "type": "string",
+                "pattern": "^https?://.*$",
+                "errorMessage": "Please provide a valid Seqera Platform API URL (e.g. https://api.cloud.seqera.io)",
+                "meta": ["platform"]
+            },
+            "token_env": {
+                "type": "string",
+                "pattern": "^[A-Za-z_][A-Za-z0-9_]*$",
+                "errorMessage": "Please provide a valid environment variable name (e.g. TOWER_PROD_TOKEN)",
+                "meta": ["token_env"]
             }
         },
         "required": ["id", "workspace"]

lib/SeqeraApi.groovy

@@ -64,17 +64,28 @@ class SeqeraApi {
 
     /**
      * Fetch all data for a single run. Returns map with workflow, metrics, tasks, progress.
+     *
+     * Per-row overrides (from the input samplesheet):
+     *   meta.platform  – Seqera Platform API URL; falls back to the global apiEndpoint
+     *   meta.token_env – env-var name holding the bearer token; falls back to TOWER_ACCESS_TOKEN
      */
     static Map fetchRunData(Map meta, String apiEndpoint) {
-        def token = System.getenv("TOWER_ACCESS_TOKEN")
+        def effectiveEndpoint = meta.platform ?: apiEndpoint
+        def tokenEnvVar = meta.token_env ?: "TOWER_ACCESS_TOKEN"
+        def token = System.getenv(tokenEnvVar)
+        if (!token) {
+            throw new RuntimeException(
+                "Environment variable '${tokenEnvVar}' is not set (required for run ${meta.id})"
+            )
+        }
         def headers = ["Authorization": "Bearer ${token}"]
-        def wsId = resolveWorkspaceId(meta.workspace, apiEndpoint, headers)
-        def base = "${apiEndpoint}/workflow/${meta.id}?workspaceId=${wsId}"
+        def wsId = resolveWorkspaceId(meta.workspace, effectiveEndpoint, headers)
+        def base = "${effectiveEndpoint}/workflow/${meta.id}?workspaceId=${wsId}"
 
         def workflow = apiGet(base, headers)
-        def metrics = apiGet("${apiEndpoint}/workflow/${meta.id}/metrics?workspaceId=${wsId}", headers)
-        def tasks = apiGetAllTasks("${apiEndpoint}/workflow/${meta.id}/tasks?workspaceId=${wsId}", headers)
-        def progress = apiGet("${apiEndpoint}/workflow/${meta.id}/progress?workspaceId=${wsId}", headers)
+        def metrics = apiGet("${effectiveEndpoint}/workflow/${meta.id}/metrics?workspaceId=${wsId}", headers)
+        def tasks = apiGetAllTasks("${effectiveEndpoint}/workflow/${meta.id}/tasks?workspaceId=${wsId}", headers)
+        def progress = apiGet("${effectiveEndpoint}/workflow/${meta.id}/progress?workspaceId=${wsId}", headers)
 
         return [
             workflow: workflow?.workflow,

workflows/nf_aggregate/main.nf

@@ -75,7 +75,13 @@ workflow NF_AGGREGATE {
                     Thread.sleep(sleepMs)
                 }
             }
-            data.meta = [id: meta.id, workspace: meta.workspace, group: meta.group ?: 'default']
+            data.meta = [
+                id:        meta.id,
+                workspace: meta.workspace,
+                group:     meta.group ?: 'default',
+                platform:  meta.platform ?: null,
+                token_env: meta.token_env ?: null,
+            ]
             def tmpDir = java.nio.file.Files.createTempDirectory("nf-agg-run-${meta.id}-")
             def json_file = file(tmpDir.resolve("${meta.id}.json"))
             json_file.text = groovy.json.JsonOutput.toJson(data)