diff --git a/internal/bundle/basic_test.go b/internal/bundle/basic_test.go index 6eb3d10f..c24ef0c0 100644 --- a/internal/bundle/basic_test.go +++ b/internal/bundle/basic_test.go @@ -20,7 +20,7 @@ func TestAccBasicBundleDeployWithFailOnActiveRuns(t *testing.T) { root, err := initTestTemplate(t, ctx, "basic", map[string]any{ "unique_id": uniqueId, "node_type_id": nodeTypeId, - "spark_version": "13.2.x-snapshot-scala2.12", + "spark_version": defaultSparkVersion, }) require.NoError(t, err) diff --git a/internal/bundle/helpers.go b/internal/bundle/helpers.go index c73d6ad0..560a0474 100644 --- a/internal/bundle/helpers.go +++ b/internal/bundle/helpers.go @@ -18,6 +18,8 @@ import ( "github.com/stretchr/testify/require" ) +const defaultSparkVersion = "13.3.x-snapshot-scala2.12" + func initTestTemplate(t *testing.T, ctx context.Context, templateName string, config map[string]any) (string, error) { templateRoot := filepath.Join("bundles", templateName) diff --git a/internal/bundle/job_metadata_test.go b/internal/bundle/job_metadata_test.go index cb3ad081..21f1086a 100644 --- a/internal/bundle/job_metadata_test.go +++ b/internal/bundle/job_metadata_test.go @@ -28,7 +28,7 @@ func TestAccJobsMetadataFile(t *testing.T) { bundleRoot, err := initTestTemplate(t, ctx, "job_metadata", map[string]any{ "unique_id": uniqueId, "node_type_id": nodeTypeId, - "spark_version": "13.2.x-snapshot-scala2.12", + "spark_version": defaultSparkVersion, }) require.NoError(t, err) diff --git a/internal/bundle/local_state_staleness_test.go b/internal/bundle/local_state_staleness_test.go index 872ac8a8..d1123466 100644 --- a/internal/bundle/local_state_staleness_test.go +++ b/internal/bundle/local_state_staleness_test.go @@ -31,7 +31,7 @@ func TestAccLocalStateStaleness(t *testing.T) { root, err := initTestTemplate(t, ctx, "basic", map[string]any{ "unique_id": uniqueId, "node_type_id": nodeTypeId, - "spark_version": "13.2.x-snapshot-scala2.12", + "spark_version": defaultSparkVersion, }) require.NoError(t, err) diff --git a/internal/bundle/python_wheel_test.go b/internal/bundle/python_wheel_test.go index fc14fd17..1299194b 100644 --- a/internal/bundle/python_wheel_test.go +++ b/internal/bundle/python_wheel_test.go @@ -43,7 +43,8 @@ func runPythonWheelTest(t *testing.T, sparkVersion string, pythonWheelWrapper bo } func TestAccPythonWheelTaskDeployAndRunWithoutWrapper(t *testing.T) { - runPythonWheelTest(t, "13.2.x-snapshot-scala2.12", false) + // This is the first DBR version where we can install Python wheels from the Workspace File System. + runPythonWheelTest(t, "13.3.x-snapshot-scala2.12", false) } func TestAccPythonWheelTaskDeployAndRunWithWrapper(t *testing.T) {