gordias.dask_setup.progress

gordias.dask_setup.progress(fs: Any) → Any

Perform outstanding calculations similar to distributed.diagnostics.progressbar.progress().

Detects whether we are in an interactive environment or not. In an interactive environment we use distributed.diagnostics.progressbar.progress() to output a dynamic progress bar during the calculations. In a non-interactive setting, we don’t output anything and just distributed.wait() for the end of the calculations. This is useful to keep log files clean for HPC jobs.

Parameters:

fs (distributed.Future) – A list of futures or keys to track.