@@ -35,6 +35,7 @@ def slurm_run(
35
35
max_simultaneous_jobs : int = 100 ,
36
36
exclusive : bool = True ,
37
37
executor_type : EXECUTOR_TYPES = "process-pool" ,
38
+ extra_scheduler : list [str ] | tuple [list [str ], ...] | None = None ,
38
39
extra_run_manager_kwargs : dict [str , Any ] | None = None ,
39
40
extra_scheduler_kwargs : dict [str , Any ] | None = None ,
40
41
initializers : list [Callable [[], None ]] | None = None ,
@@ -93,6 +94,9 @@ def slurm_run(
93
94
"loky", or "process-pool".
94
95
exclusive
95
96
Whether to use exclusive nodes, adds ``"--exclusive"`` if True.
97
+ extra_scheduler
98
+ Extra ``#SLURM`` (depending on scheduler type)
99
+ arguments, e.g. ``["--exclusive=user", "--time=1"]``.
96
100
extra_run_manager_kwargs
97
101
Extra keyword arguments to pass to the `RunManager`.
98
102
extra_scheduler_kwargs
@@ -104,6 +108,7 @@ def slurm_run(
104
108
Returns
105
109
-------
106
110
RunManager
111
+
107
112
"""
108
113
if partition is None :
109
114
partitions = slurm_partitions ()
@@ -143,6 +148,7 @@ def slurm_run(
143
148
executor_type = executor_type ,
144
149
num_threads = num_threads ,
145
150
exclusive = exclusive ,
151
+ extra_scheduler = extra_scheduler ,
146
152
** (extra_scheduler_kwargs or {}),
147
153
)
148
154
scheduler = SLURM (** slurm_kwargs )
0 commit comments