fix issue with publish

Signed-off-by: jorgee <jorge.ejarque@seqera.io>
nextflow-io · Jan 24, 2025 · 76ff6d8 · 76ff6d8
1 parent 8487592
commit 76ff6d8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/modules/nextflow/src/main/groovy/nextflow/prov/openlineage/OpenLineageEventFactory.groovy b/modules/nextflow/src/main/groovy/nextflow/prov/openlineage/OpenLineageEventFactory.groovy
@@ -105,9 +105,9 @@ class OpenLineageEventFactory {
     }
 
 
-    private static OpenLineage.Job generatePublishJob(){
+    private OpenLineage.Job generatePublishJob(){
         final jobType = OL.newJobTypeJobFacet("BATCH", "Nextflow", "JOB")
-        return OL.newJobBuilder().namespace("io.nextflow").name("publish (${publishCount.getAndIncrement()})")
+        return OL.newJobBuilder().namespace(this.workflow.namespace).name("publish (${publishCount.getAndIncrement()})")
             .facets(OL.newJobFacetsBuilder().jobType(jobType).build())
             .build()
     }