chore: Removes datalake from test cleanup (#4264)

Author: cveticm

test/internal/cleanup_test.go

@@ -127,10 +127,6 @@ func TestCleanup(t *testing.T) {
 				t.Parallel()
 				deleteAllClustersForProject(t, cliPath, projectID)
 			})
-			t.Run("delete datapipelines", func(t *testing.T) {
-				t.Parallel()
-				deleteDatapipelinesForProject(t, cliPath, projectID)
-			})
 			t.Run("delete data federations", func(t *testing.T) {
 				t.Parallel()
 				deleteAllDataFederations(t, cliPath, projectID)

test/internal/helper.go

@@ -55,7 +55,6 @@ const (
 	indexEntity                   = "index"
 	nodesEntity                   = "nodes"
 	datafederationEntity          = "datafederation"
-	datalakePipelineEntity        = "datalakepipeline"
 	alertsEntity                  = "alerts"
 	configEntity                  = "config"
 	dbusersEntity                 = "dbusers"
@@ -402,26 +401,6 @@ func DeleteClusterForProject(projectID, clusterName string) error {
 	return nil
 }
 
-func deleteDatalakeForProject(cliPath, projectID, id string) error {
-	args := []string{
-		datalakePipelineEntity,
-		"delete",
-		id,
-		"--force",
-		"-P",
-		ProfileName(),
-	}
-	if projectID != "" {
-		args = append(args, "--projectId", projectID)
-	}
-	deleteCmd := exec.Command(cliPath, args...)
-	deleteCmd.Env = os.Environ()
-	if resp, err := RunAndGetStdOut(deleteCmd); err != nil {
-		return fmt.Errorf("error deleting datalake %w: %s", err, string(resp))
-	}
-	return nil
-}
-
 func NewAvailableRegion(projectID, tier, provider string) (string, error) {
 	cliPath, err := AtlasCLIBin()
 	if err != nil {
@@ -755,27 +734,6 @@ func deleteAllClustersForProject(t *testing.T, cliPath, projectID string) {
 	}
 }
 
-func deleteDatapipelinesForProject(t *testing.T, cliPath, projectID string) {
-	t.Helper()
-	cmd := exec.Command(cliPath, //nolint:gosec // needed for e2e tests
-		datalakePipelineEntity,
-		"list",
-		"--projectId", projectID,
-		"-o=json",
-		"-P",
-		ProfileName(),
-	)
-	cmd.Env = os.Environ()
-	resp, err := RunAndGetStdOut(cmd)
-	t.Log(string(resp))
-	require.NoError(t, err, string(resp))
-	var pipelines []atlasv2.DataLakeIngestionPipeline
-	require.NoError(t, json.Unmarshal(resp, &pipelines))
-	for _, p := range pipelines {
-		assert.NoError(t, deleteDatalakeForProject(cliPath, projectID, p.GetName()))
-	}
-}
-
 func deleteAllNetworkPeers(t *testing.T, cliPath, projectID, provider string) {
 	t.Helper()
 	cmd := exec.Command(cliPath, //nolint:gosec // needed for e2e tests