Wait until computation has finished This is a compatibility alias for ``dask.distributed.wait``. If it is applied onto Dask collections without Dask Futures or if Dask distributed is not installed then it is a no-op
(x, timeout=None, return_when="ALL_COMPLETED")
| 1314 | |
| 1315 | |
| 1316 | def wait(x, timeout=None, return_when="ALL_COMPLETED"): |
| 1317 | """Wait until computation has finished |
| 1318 | |
| 1319 | This is a compatibility alias for ``dask.distributed.wait``. |
| 1320 | If it is applied onto Dask collections without Dask Futures or if Dask |
| 1321 | distributed is not installed then it is a no-op |
| 1322 | """ |
| 1323 | try: |
| 1324 | from distributed import wait |
| 1325 | |
| 1326 | return wait(x, timeout=timeout, return_when=return_when) |
| 1327 | except (ImportError, ValueError): |
| 1328 | return x |
| 1329 | |
| 1330 | |
| 1331 | def get_collection_names(collection) -> set[str]: |
no outgoing calls