Jim Crist-Harif
05/06/2020, 3:45 PMEnvironment
class per dask-cluster class, and it seems a bit untenable. I've been thinking about making a generic dask environment that takes the cluster-manager class and kwargs and uses that to create a dask cluster. Since dask already has a spec'd interface for this, it seems significantly simpler than having a mirror of each of these in prefect. Something like (class name not decided):
environment = DaskClusterEnvironment(
cls=dask_yarn.YarnCluster,
kwargs={
"queue": "engineering",
"environment": "hdfs://..."
}
)
Joe Schmid
05/06/2020, 3:50 PMJim Crist-Harif
05/06/2020, 3:57 PMDavid Ojeda
05/06/2020, 3:58 PMJim Crist-Harif
05/06/2020, 4:00 PMEnvironment
class that won't require prefect to mirror all of dask's deployment classes.