punchbowl.auto.cluster#
This process starts a Dask cluster and then monitors for changes to the cluster size in the configuration file
Functions#
|
Run a Dask cluster for the pipeline |
Module Contents#
- punchbowl.auto.cluster.main()#
Run a Dask cluster for the pipeline