|
3 | 3 | from executorlib._version import get_versions as _get_versions
|
4 | 4 | from executorlib.interactive.executor import ExecutorWithDependencies, create_executor
|
5 | 5 | from executorlib.standalone.inputcheck import (
|
6 |
| - check_plot_dependency_graph as _check_plot_dependency_graph, |
| 6 | + check_executor as _check_executor, |
7 | 7 | )
|
8 | 8 | from executorlib.standalone.inputcheck import (
|
9 |
| - check_refresh_rate as _check_refresh_rate, |
| 9 | + check_nested_flux_executor as _check_nested_flux_executor, |
10 | 10 | )
|
11 | 11 | from executorlib.standalone.inputcheck import (
|
12 |
| - check_executor as _check_executor, |
| 12 | + check_plot_dependency_graph as _check_plot_dependency_graph, |
13 | 13 | )
|
14 | 14 | from executorlib.standalone.inputcheck import (
|
15 |
| - check_nested_flux_executor as _check_nested_flux_executor, |
| 15 | + check_refresh_rate as _check_refresh_rate, |
16 | 16 | )
|
17 | 17 |
|
18 | 18 | __version__ = _get_versions()["version"]
|
@@ -210,15 +210,25 @@ def __new__(
|
210 | 210 | if cache_directory is None:
|
211 | 211 | cache_directory = "executorlib_cache"
|
212 | 212 | if max_workers != 1:
|
213 |
| - raise ValueError("The number of workers cannot be controlled with the pysqa based backend.") |
| 213 | + raise ValueError( |
| 214 | + "The number of workers cannot be controlled with the pysqa based backend." |
| 215 | + ) |
214 | 216 | if max_cores != 1:
|
215 |
| - raise ValueError("The number of cores cannot be controlled with the pysqa based backend.") |
| 217 | + raise ValueError( |
| 218 | + "The number of cores cannot be controlled with the pysqa based backend." |
| 219 | + ) |
216 | 220 | if hostname_localhost is not None:
|
217 |
| - raise ValueError("The option to connect to hosts based on their hostname is not available with the pysqa based backend.") |
| 221 | + raise ValueError( |
| 222 | + "The option to connect to hosts based on their hostname is not available with the pysqa based backend." |
| 223 | + ) |
218 | 224 | if block_allocation:
|
219 |
| - raise ValueError("The option block_allocation is not available with the pysqa based backend.") |
| 225 | + raise ValueError( |
| 226 | + "The option block_allocation is not available with the pysqa based backend." |
| 227 | + ) |
220 | 228 | if init_function is not None:
|
221 |
| - raise ValueError("The option to specify an init_function is not available with the pysqa based backend.") |
| 229 | + raise ValueError( |
| 230 | + "The option to specify an init_function is not available with the pysqa based backend." |
| 231 | + ) |
222 | 232 | _check_executor(executor=flux_executor)
|
223 | 233 | _check_nested_flux_executor(nested_flux_executor=flux_executor_nesting)
|
224 | 234 | return FileExecutor(
|
|
0 commit comments