Bug/542/dask cluster error

[blythed]

Description

In the code state in main jobs are submitted to the dask cluster, and insider each job,
the database is rebuilt using build_datalayer, based on s.CFG.

Since CFG is not changed, then CFG.distributed == True, so the job will attempt
to build another local daskcluster, add infinitum.

I fixed this configuration issue inside the function wrappers which Dask runs.

In addition, I added a utility function TaskWorkflow.watch to monitor submitted jobs.

Related Issue(s)

#542

There'a notebook testing these changes

Checklist

• Change or addition is covered by unit and/or integration tests. If bugfix, there should be at least one test that fails pre-PR and passes after.
• Classes and functions substantially affected by this PR have sphinx format docstrings added or updated.
• If your changes introduce modifications to functionality, behavior, or usage of the project, please ensure that the documentation is updated accordingly.