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")
| 1201 | |
| 1202 | |
| 1203 | def wait(x, timeout=None, return_when="ALL_COMPLETED"): |
| 1204 | """Wait until computation has finished |
| 1205 | |
| 1206 | This is a compatibility alias for ``dask.distributed.wait``. |
| 1207 | If it is applied onto Dask collections without Dask Futures or if Dask |
| 1208 | distributed is not installed then it is a no-op |
| 1209 | """ |
| 1210 | try: |
| 1211 | from distributed import wait |
| 1212 | |
| 1213 | return wait(x, timeout=timeout, return_when=return_when) |
| 1214 | except (ImportError, ValueError): |
| 1215 | return x |
| 1216 | |
| 1217 | |
| 1218 | def get_collection_names(collection) -> set[str]: |
no outgoing calls