From 941e2d17fea0949b62a5bee0a40a59db171be219 Mon Sep 17 00:00:00 2001
From: Jordan Frazier <jordan.frazier@datastax.com>
Date: Mon, 31 Jul 2023 10:55:07 -0700
Subject: [PATCH] remove integ tests changes

---
 tests/integration/api/api_suite_test.go       | 21 -------------------
 .../api/query_v1_incremental_test.go          |  4 +---
 2 files changed, 1 insertion(+), 24 deletions(-)

diff --git a/tests/integration/api/api_suite_test.go b/tests/integration/api/api_suite_test.go
index 067469941..c25b987b7 100644
--- a/tests/integration/api/api_suite_test.go
+++ b/tests/integration/api/api_suite_test.go
@@ -204,27 +204,6 @@ func primitiveSchemaField(name string, primitiveType v1alpha.DataType_PrimitiveT
 	}
 }
 
-func listSchemaField(name string, primitiveType v1alpha.DataType_PrimitiveType) *v1alpha.Schema_Field {
-	return &v1alpha.Schema_Field{
-		Name: name,
-		DataType: &v1alpha.DataType{
-			Kind: &v1alpha.DataType_List_{
-				List: &v1alpha.DataType_List{
-					Name: name,
-					ItemType: &v1alpha.DataType{
-						Kind: &v1alpha.DataType_Primitive{
-							Primitive: primitiveType,
-						},
-					},
-					Nullable: true,
-				},
-			},
-		},
-		Nullable: true,
-	}
-
-}
-
 func getRemotePulsarHostname() string {
 	if os.Getenv("ENV") == "local-local" {
 		return "localhost"
diff --git a/tests/integration/api/query_v1_incremental_test.go b/tests/integration/api/query_v1_incremental_test.go
index 61f744ee6..1c298b6b2 100644
--- a/tests/integration/api/query_v1_incremental_test.go
+++ b/tests/integration/api/query_v1_incremental_test.go
@@ -19,7 +19,7 @@ import (
 	"github.com/jt-nti/gproto"
 )
 
-var _ = FDescribe("Query V1 with incremental", Ordered, func() {
+var _ = Describe("Query V1 with incremental", Ordered, func() {
 	var (
 		ctx                        context.Context
 		cancel                     context.CancelFunc
@@ -79,7 +79,6 @@ var _ = FDescribe("Query V1 with incremental", Ordered, func() {
 		entity: table.customer_id,
 		max_amount: table.amount | max(),
 		min_amount: table.amount | min(),
-		collect: table.amount | collect(2),
 		}`
 
 		expressionIncremental = strings.ReplaceAll(expressionTemplate, "table", tableIncremental.TableName)
@@ -157,7 +156,6 @@ var _ = FDescribe("Query V1 with incremental", Ordered, func() {
 					gproto.Equal(primitiveSchemaField("entity", v1alpha.DataType_PRIMITIVE_TYPE_STRING)),
 					gproto.Equal(primitiveSchemaField("max_amount", v1alpha.DataType_PRIMITIVE_TYPE_I64)),
 					gproto.Equal(primitiveSchemaField("min_amount", v1alpha.DataType_PRIMITIVE_TYPE_I64)),
-					gproto.Equal(primitiveSchemaField("collect", v1alpha.DataType_PRIMITIVE_TYPE_BOOL)),
 				))
 				_, err = uuid.Parse(secondResponse.QueryId)
 				Expect(err).Should(BeNil())