steve/databricks-cli
steve
/
databricks-cli
mirror of https://github.com/databricks/cli.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fixed tests after rebase

This commit is contained in:
Andrew Nester 2024-12-16 15:29:04 +01:00
parent 438c19f2af
commit dde1b020fc
No known key found for this signature in database
GPG Key ID: 12BC628A44B7DA57
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
integration/bundle/apps_test.go
View File

@ -20,19 +20,16 @@ func TestAccDeployBundleWithApp(t *testing.T) {
nodeTypeId := testutil.GetCloud(t).NodeTypeID() nodeTypeId := testutil.GetCloud(t).NodeTypeID()
instancePoolId := env.Get(ctx, "TEST_INSTANCE_POOL_ID") instancePoolId := env.Get(ctx, "TEST_INSTANCE_POOL_ID")
root, err := initTestTemplate(t, ctx, "apps", map[string]any{ root := initTestTemplate(t, ctx, "apps", map[string]any{
"unique_id": uniqueId, "unique_id": uniqueId,
"app_id": appId, "app_id": appId,
"node_type_id": nodeTypeId, "node_type_id": nodeTypeId,
"spark_version": defaultSparkVersion, "spark_version": defaultSparkVersion,
"instance_pool_id": instancePoolId, "instance_pool_id": instancePoolId,
}) })
require.NoError(t, err)
t.Cleanup(func() { t.Cleanup(func() {
err = destroyBundle(t, ctx, root) destroyBundle(t, ctx, root)
require.NoError(t, err)
app, err := wt.W.Apps.Get(ctx, apps.GetAppRequest{Name: "test-app"}) app, err := wt.W.Apps.Get(ctx, apps.GetAppRequest{Name: "test-app"})
if err != nil { if err != nil {
require.ErrorContains(t, err, "does not exist") require.ErrorContains(t, err, "does not exist")
@ -41,8 +38,7 @@ func TestAccDeployBundleWithApp(t *testing.T) {
} }
}) })
err = deployBundle(t, ctx, root) deployBundle(t, ctx, root)
require.NoError(t, err)
// App should exists after bundle deployment // App should exists after bundle deployment
app, err := wt.W.Apps.Get(ctx, apps.GetAppRequest{Name: appId}) app, err := wt.W.Apps.Get(ctx, apps.GetAppRequest{Name: appId})
@ -61,6 +57,7 @@ func TestAccDeployBundleWithApp(t *testing.T) {
require.NoError(t, err) require.NoError(t, err)
job, err := wt.W.Jobs.GetBySettingsName(ctx, fmt.Sprintf("test-job-with-cluster-%s", uniqueId)) job, err := wt.W.Jobs.GetBySettingsName(ctx, fmt.Sprintf("test-job-with-cluster-%s", uniqueId))
require.NoError(t, err)
content := string(data) content := string(data)
require.Contains(t, content, fmt.Sprintf(`command: require.Contains(t, content, fmt.Sprintf(`command: