remove integ tests changes

kaskada-ai · Jul 31, 2023 · 941e2d1 · 941e2d1
1 parent 6229b70
commit 941e2d1
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 24 deletions.
diff --git 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
@@ -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())