Commit 24bd0a0
committed
feat: Implement task-level Fusion override via disk directive
Enable per-task control of Fusion filesystem by checking the disk.fusion
setting before falling back to executor-level configuration.
Changes:
- Modify fusionEnabled() in FusionAwareTask to check task's disk.fusion
setting first
- Fall back to executor.isFusionEnabled() if disk.fusion is not specified
- Task-level setting takes priority over global fusion.enabled config
- Add null-safe navigation for config to handle cases where task config
may not be set (e.g., in test mocks)
Priority order:
1. Task-level disk.fusion setting (highest)
2. Executor/session-level fusion.enabled config (fallback)
This provides a clearer alternative to using "scratch false" for
disabling Fusion on problematic tasks.
Signed-off-by: Edmund Miller <edmund.miller@seqera.io>1 parent cd044ff commit 24bd0a0
File tree
1 file changed
+8
-1
lines changed- modules/nextflow/src/main/groovy/nextflow/fusion
1 file changed
+8
-1
lines changedLines changed: 8 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
45 | | - | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
46 | 53 | | |
47 | 54 | | |
48 | 55 | | |
| |||
0 commit comments