Return the global Dask cluster configuration.
()
| 137 | |
| 138 | |
| 139 | def get_parallel_config() -> Optional[DictConfig]: |
| 140 | """Return the global Dask cluster configuration.""" |
| 141 | return parallel_config |
| 142 | |
| 143 | |
| 144 | def _build_client(config: DictConfig = None) -> Client: |
no outgoing calls
searching dependent graphs…