Skip to content

Commit 9fe7490

Browse files
Use default cluster for model serving integration test (#2461)
* wip default cluster for mlflow test * Fix model serving integration test * Use default cluster for model serving integration test --------- Co-authored-by: Miles Yucht <[email protected]>
1 parent 5dff9ed commit 9fe7490

File tree

1 file changed

+12
-22
lines changed

1 file changed

+12
-22
lines changed

internal/acceptance/model_serving_test.go

Lines changed: 12 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -20,41 +20,31 @@ func TestAccModelServing(t *testing.T) {
2020
t.Skipf("not available on %s", cloudEnv)
2121
}
2222

23+
clusterID := os.Getenv("TEST_DEFAULT_CLUSTER_ID")
24+
if clusterID == "" {
25+
t.Skipf("default cluster not available")
26+
}
27+
2328
name := fmt.Sprintf("terraform-test-model-serving-%[1]s",
2429
acctest.RandStringFromCharSet(5, acctest.CharSetAlphaNum))
2530
workspaceLevel(t, step{
2631
Template: fmt.Sprintf(`
27-
data "databricks_spark_version" "latest" {
28-
}
29-
resource "databricks_cluster" "this" {
30-
cluster_name = "singlenode-{var.RANDOM}"
31-
spark_version = data.databricks_spark_version.latest.id
32-
instance_pool_id = "{env.TEST_INSTANCE_POOL_ID}"
33-
num_workers = 0
34-
autotermination_minutes = 10
35-
spark_conf = {
36-
"spark.databricks.cluster.profile" = "singleNode"
37-
"spark.master" = "local[*]"
38-
}
39-
custom_tags = {
40-
"ResourceClass" = "SingleNode"
41-
}
42-
library {
43-
pypi {
44-
package = "mlflow"
45-
}
46-
}
47-
}
4832
resource "databricks_mlflow_experiment" "exp" {
4933
name = "/Shared/%[1]s-exp"
5034
}
5135
resource "databricks_mlflow_model" "model" {
5236
name = "%[1]s-model"
5337
}
38+
resource "databricks_library" "fbprophet" {
39+
cluster_id = "{env.TEST_DEFAULT_CLUSTER_ID}"
40+
pypi {
41+
package = "mlflow"
42+
}
43+
}
44+
5445
`, name),
5546
Check: func(s *terraform.State) error {
5647
w := databricks.Must(databricks.NewWorkspaceClient())
57-
clusterID := s.RootModule().Resources["databricks_cluster.this"].Primary.ID
5848
ctx := context.Background()
5949
executor, err := w.CommandExecution.Start(ctx, clusterID, compute.LanguagePython)
6050
if err != nil {

0 commit comments

Comments
 (0)