diff --git a/cmd/graphql.ethereum/graph/schema.resolvers.go b/cmd/graphql.ethereum/graph/schema.resolvers.go
index 9b4c9299..73d81572 100644
--- a/cmd/graphql.ethereum/graph/schema.resolvers.go
+++ b/cmd/graphql.ethereum/graph/schema.resolvers.go
@@ -481,7 +481,7 @@ func (r *queryResolver) GetSwaps(ctx context.Context, pool string, first *int, a
 	var d []model.SeawaterSwap
 	// DB.RAW doesn't support chaining
 	err = r.DB.Raw(
-		"SELECT * FROM seawater_swaps_pool_3(?, ?, ?, ?, ?)",
+		"SELECT * FROM seawater_swaps_pool_2(?, ?, ?, ?, ?)",
 		r.C.FusdcAddr,
 		r.C.FusdcDecimals,
 		poolAddress,
@@ -528,7 +528,7 @@ func (r *queryResolver) GetSwapsForUser(ctx context.Context, wallet string, firs
 	var d []model.SeawaterSwap
 	// DB.RAW doesn't support chaining
 	err = r.DB.Raw(
-		"SELECT * FROM seawater_swaps_user_3(?, ?, ?, ?, ?)",
+		"SELECT * FROM seawater_swaps_user_2(?, ?, ?, ?, ?)",
 		r.C.FusdcAddr,
 		r.C.FusdcDecimals,
 		walletAddress,
@@ -1268,7 +1268,7 @@ func (r *seawaterPoolResolver) Swaps(ctx context.Context, obj *seawater.Pool, fi
 	}
 	// DB.RAW doesn't support chaining
 	err = r.DB.Raw(
-		"SELECT * FROM seawater_swaps_pool_3(?, ?, ?, ?, ?)",
+		"SELECT * FROM seawater_swaps_pool_2(?, ?, ?, ?, ?)",
 		r.C.FusdcAddr,
 		r.C.FusdcDecimals,
 		obj.Token,