Use Selector for cluster config config options

Only one cluster type may be configured. It is not valid to create multiple clusters for a client.
dagster-io · Sep 7, 2020 · a90de96 · a90de96
1 parent ac70a36
commit a90de96
Showing 1 changed file with 10 additions and 8 deletions.
diff --git a/python_modules/libraries/dagster-dask/dagster_dask/resources.py b/python_modules/libraries/dagster-dask/dagster_dask/resources.py
@@ -121,14 +121,16 @@ def client(self):
                 is_required=False,
             ),
             "cluster": Field(
-                {
-                    key: Field(
-                        Permissive(),
-                        is_required=False,
-                        description=f"{meta['name']} cluster configuration.",
-                    )
-                    for key, meta in DaskClusterTypes.items()
-                },
+                Selector(
+                    {
+                        key: Field(
+                            Permissive(),
+                            is_required=False,
+                            description=f"{meta['name']} cluster configuration.",
+                        )
+                        for key, meta in DaskClusterTypes.items()
+                    }
+                ),
                 description="Create a Dask cluster. Will be passed as the client address.",
                 is_required=False,
             ),