Make the container directive optional when using Azure Batch

Signed-off-by: adamrtalbot <12817534+adamrtalbot@users.noreply.github.com>

Author: adamrtalbot

plugins/nf-azure/src/main/nextflow/cloud/azure/batch/AzBatchService.groovy

@@ -393,7 +393,7 @@ class AzBatchService implements Closeable {
 
         final container = task.getContainer()
         if( !container )
-            throw new IllegalArgumentException("Missing container image for process: $task.name")
+            log.warn "Missing container image for process: $task.name"
         final taskId = "nf-${task.hash.toString()}"
         // get the pool config
         final pool = getPoolSpec(poolId)
@@ -419,8 +419,11 @@ class AzBatchService implements Closeable {
             }
         }
         // config overall container settings
-        final containerOpts = new BatchTaskContainerSettings(container)
+        BatchTaskContainerSettings containerOpts = null
+        if (container) {
+            containerOpts = new BatchTaskContainerSettings(container)
                 .setContainerRunOptions(opts)
+        }
         // submit command line
         final String cmd = fusionEnabled
                 ? launcher.fusionSubmitCli(task).join(' ')

plugins/nf-azure/src/main/nextflow/cloud/azure/batch/AzBatchTaskHandler.groovy

@@ -60,7 +60,6 @@ class AzBatchTaskHandler extends TaskHandler implements FusionAwareTask {
         this.outputFile = task.workDir.resolve(TaskRun.CMD_OUTFILE)
         this.errorFile = task.workDir.resolve(TaskRun.CMD_ERRFILE)
         this.exitFile = task.workDir.resolve(TaskRun.CMD_EXIT)
-        validateConfiguration()
     }
 
     /** only for testing purpose - DO NOT USE */
@@ -70,12 +69,6 @@ class AzBatchTaskHandler extends TaskHandler implements FusionAwareTask {
         return executor.batchService
     }
 
-    void validateConfiguration() {
-        if (!task.container) {
-            throw new ProcessUnrecoverableException("No container image specified for process $task.name -- Either specify the container to use in the process definition or with 'process.container' value in your config")
-        }
-    }
-
     protected BashWrapperBuilder createBashWrapper() {
         fusionEnabled()
                 ? fusionLauncher()