Update documentation with publishOffload options

Signed-off-by: jorgee <jorge.ejarque@seqera.io>

Author: jorgee

docs/reference/config.md

@@ -1300,6 +1300,37 @@ The following settings are available:
 
 Read the {ref}`container-podman` page to learn more about how to use Podman containers with Nextflow.
 
+(config-publishOffload)=
+
+## `publishOffload`
+
+The `publishOffload` scope allows you to configure the offload of the publication of workflow output as remote tasks. An internal `offload:publish_process` is created to offload the file operation (copies and moves) required to publish the output files. This functionality is currently available for 's3' files with the 'awsbatch' executor. File operations can be maneged with `s5cmd` (default option) of Fusion. 
+
+The following settings are available:
+
+`publishOffload.enable`
+: If `true` enables the offload of workflow outputs publication. (Default: `false`)
+
+`publishOffload.batchSize`
+: Indicates the number of files operations in each `publish_process` execution. (Default: 10)
+
+`publishOffload.maxParallel`
+: Indicates the maximum number of concurrent files operations in each `publish_process` execution. If `maxParallel` is not specified, it gets the value of `batchSize`.
+
+`publishOffload.useFusion`
+: Enables the use of Fusion to manage the file operations. (Default: `false`)
+
+You can also control the resources assigned to the `publish_process` defining a process selector such as the following:
+
+```groovy
+process {
+    withName: publish_process {
+        cpus = 4
+        memory = 8.GB
+    }
+}
+```
+
 (config-report)=
 
 ## `report`

modules/nextflow/src/main/groovy/nextflow/processor/PublishOffloadManager.groovy

@@ -68,7 +68,7 @@ class PublishOffloadManager {
             engine.eval(file.text, delegate)
             return engine.result
         },'publish file process', 'script')
-        this.publishProcessor = createProcessor( "publish_process", body )
+        this.publishProcessor = createProcessor( "offload:publish_process", body )
         log.debug("Publish Offload Manager initialized.")
     }
 
@@ -156,7 +156,7 @@ class PublishOffloadManager {
             throw new IllegalArgumentException("Missing script in the specified process block -- make sure it terminates with the script string to be executed")
 
         // -- apply settings from config file to process config
-        processConfig.applyConfig((Map)session.config.process, name, name, name)
+        processConfig.applyConfig((Map)session.config.process, 'publish_process', name, name)
 
         // -- get the executor for the given process config
         final execObj = session.executorFactory.getExecutor(name, processConfig, body, session)

tests/checks/publish-offload.nf/.checks

@@ -3,5 +3,5 @@ cp .config nextflow.config
 
 $NXF_RUN > stdout
 [[ `grep 'INFO' .nextflow.log | grep -c 'Submitted process > gen_data'` == 1 ]] || false
-[[ `grep 'INFO' .nextflow.log | grep -c 'Submitted process > publish_process'` == 1 ]] || false
+[[ `grep 'INFO' .nextflow.log | grep -c 'Submitted process > offload:publish_process'` == 1 ]] || false
 [[ -f publishDir/chunk_1 ]] || false