File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -86,7 +86,9 @@ def create_executor(
8686 if flux_executor is not None and backend != "flux_allocation" :
8787 backend = "flux_allocation"
8888 if backend == "flux_allocation" :
89- check_init_function (block_allocation = block_allocation , init_function = init_function )
89+ check_init_function (
90+ block_allocation = block_allocation , init_function = init_function
91+ )
9092 check_pmi (backend = backend , pmi = flux_executor_pmi_mode )
9193 cores_per_worker = resource_dict .get ("cores" , 1 )
9294 resource_dict ["cache_directory" ] = cache_directory
@@ -161,9 +163,7 @@ def create_flux_allocation_executor(
161163 cores_per_worker = resource_dict .get ("cores" , 1 )
162164 resource_dict ["cache_directory" ] = cache_directory
163165 resource_dict ["hostname_localhost" ] = hostname_localhost
164- check_oversubscribe (
165- oversubscribe = resource_dict .get ("openmpi_oversubscribe" , False )
166- )
166+ check_oversubscribe (oversubscribe = resource_dict .get ("openmpi_oversubscribe" , False ))
167167 check_command_line_argument_lst (
168168 command_line_argument_lst = resource_dict .get ("slurm_cmd_args" , [])
169169 )
You can’t perform that action at this time.
0 commit comments