Add snapshots support to nf-seqera

Signed-off-by: Lorenzo Fontana <fontanalorenz@gmail.com>

Author: fntlnz

plugins/nf-seqera/src/main/io/seqera/executor/SeqeraTaskHandler.groovy

@@ -103,11 +103,12 @@ class SeqeraTaskHandler extends TaskHandler implements FusionAwareTask {
             if( accelerator.type )
                 resourceReq.acceleratorName(accelerator.type)
         }
-        // build machine requirement merging config settings with task arch and disk
+        // build machine requirement merging config settings with task arch, disk, and snapshot settings
         final machineReq = MapperUtil.toMachineRequirement(
             executor.getSeqeraConfig().machineRequirement,
             task.getContainerPlatform(),
-            task.config.getDisk()
+            task.config.getDisk(),
+            fusionConfig().snapshotsEnabled()
         )
         final schedTask = new Task()
             .name(task.lazyName())

plugins/nf-seqera/src/main/io/seqera/util/MapperUtil.groovy

@@ -78,33 +78,35 @@ class MapperUtil {
      * @return the MachineRequirement API object, or null if no settings
      */
     static MachineRequirement toMachineRequirement(MachineRequirementOpts opts, String taskArch) {
-        return toMachineRequirement(opts, taskArch, null)
+        return toMachineRequirement(opts, taskArch, null, false)
     }
 
     /**
-     * Maps MachineRequirementOpts to MachineRequirement API object, merging with task arch and disk.
+     * Maps MachineRequirementOpts to MachineRequirement API object, merging with task arch, disk, and snapshots.
      * Task arch overrides config arch if specified.
      *
      * @param opts the config options (can be null)
      * @param taskArch the task container platform/arch (can be null)
      * @param diskSize the disk size from task config (can be null)
+     * @param snapshotEnabled whether Fusion snapshots are enabled
      * @return the MachineRequirement API object, or null if no settings
      */
-    static MachineRequirement toMachineRequirement(MachineRequirementOpts opts, String taskArch, MemoryUnit diskSize) {
+    static MachineRequirement toMachineRequirement(MachineRequirementOpts opts, String taskArch, MemoryUnit diskSize, boolean snapshotEnabled) {
         final arch = taskArch ?: opts?.arch
         final provisioning = opts?.provisioning
         final maxSpotAttempts = opts?.maxSpotAttempts
         final machineFamilies = opts?.machineFamilies
         final diskReq = toDiskRequirement(diskSize, opts)
         // return null if no settings
-        if (!arch && !provisioning && !maxSpotAttempts && !machineFamilies && !diskReq)
+        if (!arch && !provisioning && !maxSpotAttempts && !machineFamilies && !diskReq && !snapshotEnabled)
             return null
         new MachineRequirement()
             .arch(arch)
             .provisioning(toProvisioningModel(provisioning))
             .maxSpotAttempts(maxSpotAttempts)
             .machineFamilies(machineFamilies)
             .disk(diskReq)
+            .snapshotEnabled(snapshotEnabled ? Boolean.TRUE : null)
     }
 
     /**