enable gears for redis 7.2

Author: ndyakov

gears_commands_test.go

@@ -35,7 +35,7 @@ func libCodeWithConfig(libName string) string {
 }
 
 // TODO: Drop Gears
-var _ = XDescribe("RedisGears commands", Label("gears"), func() {
+var _ = Describe("RedisGears commands", Label("gears"), func() {
 	ctx := context.TODO()
 	var client *redis.Client
 
@@ -50,6 +50,7 @@ var _ = XDescribe("RedisGears commands", Label("gears"), func() {
 	})
 
 	It("should TFunctionLoad, TFunctionLoadArgs and TFunctionDelete ", Label("gears", "tfunctionload"), func() {
+		SkipAfterRedisVersion(7.2, "gears are not working in later versions")
 		resultAdd, err := client.TFunctionLoad(ctx, libCode("lib1")).Result()
 		Expect(err).NotTo(HaveOccurred())
 		Expect(resultAdd).To(BeEquivalentTo("OK"))
@@ -59,6 +60,7 @@ var _ = XDescribe("RedisGears commands", Label("gears"), func() {
 		Expect(resultAdd).To(BeEquivalentTo("OK"))
 	})
 	It("should TFunctionList", Label("gears", "tfunctionlist"), func() {
+		SkipAfterRedisVersion(7.2, "gears are not working in later versions")
 		resultAdd, err := client.TFunctionLoad(ctx, libCode("lib1")).Result()
 		Expect(err).NotTo(HaveOccurred())
 		Expect(resultAdd).To(BeEquivalentTo("OK"))
@@ -72,6 +74,7 @@ var _ = XDescribe("RedisGears commands", Label("gears"), func() {
 	})
 
 	It("should TFCall", Label("gears", "tfcall"), func() {
+		SkipAfterRedisVersion(7.2, "gears are not working in later versions")
 		var resultAdd interface{}
 		resultAdd, err := client.TFunctionLoad(ctx, libCode("lib1")).Result()
 		Expect(err).NotTo(HaveOccurred())
@@ -82,6 +85,7 @@ var _ = XDescribe("RedisGears commands", Label("gears"), func() {
 	})
 
 	It("should TFCallArgs", Label("gears", "tfcallargs"), func() {
+		SkipAfterRedisVersion(7.2, "gears are not working in later versions")
 		var resultAdd interface{}
 		resultAdd, err := client.TFunctionLoad(ctx, libCode("lib1")).Result()
 		Expect(err).NotTo(HaveOccurred())
@@ -93,6 +97,7 @@ var _ = XDescribe("RedisGears commands", Label("gears"), func() {
 	})
 
 	It("should TFCallASYNC", Label("gears", "TFCallASYNC"), func() {
+		SkipAfterRedisVersion(7.2, "gears are not working in later versions")
 		var resultAdd interface{}
 		resultAdd, err := client.TFunctionLoad(ctx, libCode("lib1")).Result()
 		Expect(err).NotTo(HaveOccurred())
@@ -103,6 +108,7 @@ var _ = XDescribe("RedisGears commands", Label("gears"), func() {
 	})
 
 	It("should TFCallASYNCArgs", Label("gears", "TFCallASYNCargs"), func() {
+		SkipAfterRedisVersion(7.2, "gears are not working in later versions")
 		var resultAdd interface{}
 		resultAdd, err := client.TFunctionLoad(ctx, libCode("lib1")).Result()
 		Expect(err).NotTo(HaveOccurred())