File tree Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Original file line number Diff line number Diff line change @@ -226,18 +226,19 @@ def create_executor(
226
226
resource_dict ["flux_executor_nesting" ] = flux_executor_nesting
227
227
if block_allocation :
228
228
resource_dict ["init_function" ] = init_function
229
+ max_workers = validate_number_of_cores (
230
+ max_cores = max_cores ,
231
+ max_workers = max_workers ,
232
+ cores_per_worker = cores_per_worker ,
233
+ set_local_cores = False ,
234
+ )
229
235
validate_max_workers (
230
236
max_workers = max_workers ,
231
237
cores = cores_per_worker ,
232
238
threads_per_core = resource_dict ["threads_per_core" ],
233
239
)
234
240
return InteractiveExecutor (
235
- max_workers = validate_number_of_cores (
236
- max_cores = max_cores ,
237
- max_workers = max_workers ,
238
- cores_per_worker = cores_per_worker ,
239
- set_local_cores = False ,
240
- ),
241
+ max_workers = max_workers ,
241
242
executor_kwargs = resource_dict ,
242
243
spawner = FluxPythonSpawner ,
243
244
)
You can’t perform that action at this time.
0 commit comments