Update HyperQueue CLI option (#5730) [BREAKING]

Signed-off-by: Mattis Knulst <51265018+chaetognatha@users.noreply.github.com> Signed-off-by: chaetognatha <mattis.knulst@med.lu.se> Co-authored-by: chaetognatha <mattis.knulst@med.lu.se>
nextflow-io · Jan 31, 2025 · b582cb5 · b582cb5
1 parent 0a29236
commit b582cb5
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/docs/executor.md b/docs/executor.md
@@ -223,7 +223,7 @@ Resource requests and other job characteristics can be controlled via the follow
 - {ref}`process-memory`
 - {ref}`process-time`
 
-:::{note} As of Nextflow version 24.06.0-edge, HyperQueue version 0.17.0 or later is required.
+:::{note} HyperQueue version 0.20.0 or later is required.
 :::
 
 (k8s-executor)=

diff --git a/modules/nextflow/src/main/groovy/nextflow/executor/HyperQueueExecutor.groovy b/modules/nextflow/src/main/groovy/nextflow/executor/HyperQueueExecutor.groovy
@@ -59,7 +59,7 @@ class HyperQueueExecutor extends AbstractGridExecutor {
     protected List<String> getDirectives(TaskRun task, List<String> result) {
 
         result << '--name' << getJobNameFor(task)
-        result << '--log' << quote(task.workDir.resolve(TaskRun.CMD_LOG))
+        result << '--stream' << quote(task.workDir.resolve(TaskRun.CMD_LOG))
         result << '--cwd' << quote(task.workDir)
 
         // No enforcement, Hq just makes sure that the allocated value is below the limit

diff --git a/modules/nextflow/src/test/groovy/nextflow/executor/HyperQueueExecutorTest.groovy b/modules/nextflow/src/test/groovy/nextflow/executor/HyperQueueExecutorTest.groovy
@@ -117,7 +117,7 @@ class HyperQueueExecutorTest extends Specification {
         then:
         executor.getHeaders(task) == '''
             #HQ --name nf-task-1
-            #HQ --log /work/dir/.command.log
+            #HQ --stream /work/dir/.command.log
             #HQ --cwd /work/dir
             '''
             .stripIndent().leftTrim()
@@ -131,7 +131,7 @@ class HyperQueueExecutorTest extends Specification {
         then:
         executor.getHeaders(task) == '''
             #HQ --name nf-task-1
-            #HQ --log /work/dir/.command.log
+            #HQ --stream /work/dir/.command.log
             #HQ --cwd /work/dir
             #HQ --resource mem=8192
             #HQ --cpus 4