diff --git a/ingest/sqs/pools/repository/redis/redis_repository_test.go b/ingest/sqs/pools/repository/redis/redis_repository_test.go
index 025df4663b5..bc736096eb6 100644
--- a/ingest/sqs/pools/repository/redis/redis_repository_test.go
+++ b/ingest/sqs/pools/repository/redis/redis_repository_test.go
@@ -203,7 +203,7 @@ var _ = Describe("RedisRepository", func() {
 
 					err := poolRepo.StoreCFMM(ctx, []domain.CFMMPoolI{mockCFMMPool})
 					Expect(err).To(HaveOccurred())
-					Expect(err).To(Equal(domain.InvalidPoolTypeError{int32(types.Concentrated)}))
+					Expect(err).To(Equal(domain.InvalidPoolTypeError{PoolType: int32(types.Concentrated)}))
 				})
 			})
 		})
@@ -311,7 +311,7 @@ var _ = Describe("RedisRepository", func() {
 
 					err := poolRepo.StoreConcentrated(ctx, []domain.ConcentratedPoolI{mockConcentratedPool})
 					Expect(err).To(HaveOccurred())
-					Expect(err).To(Equal(domain.InvalidPoolTypeError{int32(types.Balancer)}))
+					Expect(err).To(Equal(domain.InvalidPoolTypeError{PoolType: int32(types.Balancer)}))
 				})
 			})
 		})
@@ -400,7 +400,7 @@ var _ = Describe("RedisRepository", func() {
 
 					err := poolRepo.StoreCosmWasm(ctx, []domain.CosmWasmPoolI{mockCosmWasmPool})
 					Expect(err).To(HaveOccurred())
-					Expect(err).To(Equal(domain.InvalidPoolTypeError{int32(types.Balancer)}))
+					Expect(err).To(Equal(domain.InvalidPoolTypeError{PoolType: int32(types.Balancer)}))
 				})
 			})
 		})