diff --git a/nextflow/plugins/nf-k8s/src/main/nextflow/k8s/K8sTaskHandler.groovy b/nextflow/plugins/nf-k8s/src/main/nextflow/k8s/K8sTaskHandler.groovy
index d72a3f6..ed1c3b5 100644
--- a/nextflow/plugins/nf-k8s/src/main/nextflow/k8s/K8sTaskHandler.groovy
+++ b/nextflow/plugins/nf-k8s/src/main/nextflow/k8s/K8sTaskHandler.groovy
@@ -333,7 +333,7 @@ class K8sTaskHandler extends TaskHandler implements FusionAwareTask {
      */
     @CompileDynamic
     void submitNow(String nodeName) {
-        final req = newSubmitRequest(task)
+        final req = newSubmitRequest(task, nodeName)
         final resp = useJobResource()
             ? client.jobCreate(req, yamlDebugPath())
             : client.podCreate(req, yamlDebugPath())