GODRIVER-3625 Remove driver tests for Atlas Data Lake

Author: qingyang-hu

Taskfile.yml

@@ -130,10 +130,6 @@ tasks:
   evg-test:
     - go test -exec "env PKG_CONFIG_PATH=${PKG_CONFIG_PATH} LD_LIBRARY_PATH=${LD_LIBRARY_PATH} DYLD_LIBRARY_PATH=$MACOS_LIBRARY_PATH}" ${BUILD_TAGS} -v -timeout {{.TEST_TIMEOUT}}s -p 1 ./... >> test.suite
 
-  evg-test-atlas-data-lake:
-    - ATLAS_DATA_LAKE_INTEGRATION_TEST=true go test -v ./internal/integration/unified -run TestUnifiedSpec/atlas-data-lake-testing >> spec_test.suite
-    - ATLAS_DATA_LAKE_INTEGRATION_TEST=true go test -v ./internal/integration -run TestAtlasDataLake >> spec_test.suite
-
   evg-test-enterprise-auth:
     - go run -tags gssapi ./internal/cmd/testentauth/main.go
 

internal/integration/client_test.go

@@ -724,7 +724,7 @@ func TestClient(t *testing.T) {
 func TestClient_BulkWrite(t *testing.T) {
 	mt := mtest.New(t, noClientOpts)
 
-	mtBulkWriteOpts := mtest.NewOptions().MinServerVersion("8.0").AtlasDataLake(false).ClientType(mtest.Pinned)
+	mtBulkWriteOpts := mtest.NewOptions().MinServerVersion("8.0").ClientType(mtest.Pinned)
 	mt.RunOpts("bulk write with nil filter", mtBulkWriteOpts, func(mt *mtest.T) {
 		mt.Parallel()
 

internal/integration/crud_prose_test.go

@@ -417,7 +417,7 @@ func TestErrorsCodeNamePropagated(t *testing.T) {
 }
 
 func TestClientBulkWriteProse(t *testing.T) {
-	mtOpts := mtest.NewOptions().MinServerVersion("8.0").AtlasDataLake(false).ClientType(mtest.Pinned)
+	mtOpts := mtest.NewOptions().MinServerVersion("8.0").ClientType(mtest.Pinned)
 	mt := mtest.New(t, mtOpts)
 
 	mt.Run("3. MongoClient.bulkWrite batch splits a writeModels input with greater than maxWriteBatchSize operations", func(mt *mtest.T) {
@@ -660,7 +660,7 @@ func TestClientBulkWriteProse(t *testing.T) {
 	})
 
 	mt.RunOpts("8. MongoClient.bulkWrite handles a cursor requiring getMore within a transaction",
-		mtest.NewOptions().MinServerVersion("8.0").AtlasDataLake(false).ClientType(mtest.Pinned).
+		mtest.NewOptions().MinServerVersion("8.0").ClientType(mtest.Pinned).
 			Topologies(mtest.ReplicaSet, mtest.Sharded, mtest.LoadBalanced, mtest.ShardedReplicaSet),
 		func(mt *mtest.T) {
 			var getMoreCalled int

internal/integration/csot_prose_test.go

@@ -179,7 +179,7 @@ func TestCSOTProse(t *testing.T) {
 	})
 
 	mt.RunOpts("11. multi-batch bulkWrites", mtest.NewOptions().MinServerVersion("8.0").
-		AtlasDataLake(false).Topologies(mtest.Single), func(mt *mtest.T) {
+		Topologies(mtest.Single), func(mt *mtest.T) {
 		coll := mt.CreateCollection(mtest.Collection{DB: "db", Name: "coll"}, false)
 		err := coll.Drop(context.Background())
 		require.NoError(mt, err, "Drop error: %v", err)

internal/integration/data_lake_test.go

@@ -74,7 +74,6 @@ type T struct {
 	validTopologies   []TopologyKind
 	auth              *bool
 	enterprise        *bool
-	dataLake          *bool
 	ssl               *bool
 	collCreateOpts    *options.CreateCollectionOptionsBuilder
 	requireAPIVersion *bool
@@ -855,10 +854,6 @@ func (t *T) verifyConstraints() error {
 		return fmt.Errorf("test requires enterprise value: %v, cluster enterprise value: %v", *t.enterprise,
 			testContext.enterpriseServer)
 	}
-	if t.dataLake != nil && *t.dataLake != testContext.dataLake {
-		return fmt.Errorf("test requires cluster to be data lake: %v, cluster is data lake: %v", *t.dataLake,
-			testContext.dataLake)
-	}
 	if t.requireAPIVersion != nil && *t.requireAPIVersion != testContext.requireAPIVersion {
 		return fmt.Errorf("test requires RequireAPIVersion value: %v, local RequireAPIVersion value: %v", *t.requireAPIVersion,
 			testContext.requireAPIVersion)

internal/integration/mtest/mongotest.go

@@ -309,14 +309,6 @@ func (op *Options) Enterprise(ent bool) *Options {
 	return op
 }
 
-// AtlasDataLake specifies whether this test should only be run against Atlas Data Lake servers. Defaults to false.
-func (op *Options) AtlasDataLake(adl bool) *Options {
-	op.optFuncs = append(op.optFuncs, func(t *T) {
-		t.dataLake = &adl
-	})
-	return op
-}
-
 // RequireAPIVersion specifies whether this test should only be run when REQUIRE_API_VERSION is true. Defaults to false.
 func (op *Options) RequireAPIVersion(rav bool) *Options {
 	op.optFuncs = append(op.optFuncs, func(t *T) {

internal/integration/mtest/options.go

@@ -99,9 +99,6 @@ func runTestFile(t *testing.T, filepath string, expectValidFail bool, opts ...*O
 	mtOpts := mtest.NewOptions().
 		RunOn(fileReqs...).
 		CreateClient(false)
-	if strings.Contains(filepath, "atlas-data-lake-testing") {
-		mtOpts.AtlasDataLake(true)
-	}
 	mt := mtest.New(t, mtOpts)
 
 	for _, testCase := range testCases {

internal/integration/unified/unified_spec_runner.go

@@ -36,7 +36,6 @@ var (
 		"server-discovery-and-monitoring/tests/unified",
 		"run-command/tests/unified",
 		"index-management/tests",
-		"atlas-data-lake-testing/tests/unified",
 	}
 	failDirectories = []string{
 		"unified-test-format/tests/valid-fail",

internal/integration/unified/unified_spec_test.go

@@ -768,11 +768,6 @@ var skipTests = map[string][]string{
 		"TestUnifiedSpec/change-streams/tests/unified/change-streams.json/Test_array_truncation",
 	},
 
-	// TODO(DRIVERS-3153): Re-enable once resolved.
-	"Re-enable test following DRIVERS-3153 resolution (DRIVERS-3153)": {
-		"TestUnifiedSpec/atlas-data-lake-testing/tests/unified/getMore.json/A_successful_find_event_with_getMore",
-	},
-
 	// TODO(GODRIVER-3137): Gossip cluster time from internal MongoClient to
 	// session entities.
 	"Must advance cluster times in unified spec runner (GODRIVER-3137)": {