diff --git a/files/dbsync/rpc/get_active_stake.json b/files/dbsync/rpc/get_active_stake.json
index 1994c09f7..b1c318ac7 100644
--- a/files/dbsync/rpc/get_active_stake.json
+++ b/files/dbsync/rpc/get_active_stake.json
@@ -37,7 +37,7 @@
           ")",
           "FROM epoch_stake AS es",
           "WHERE es.epoch_no = _epoch_no",
-            "AND es.pool_id =  (SELECT id from pool_hash where view=_pool_hash_id)",
+            "AND es.pool_id =  (SELECT id from pool_hash where view=_pool_bech32)",
         ");",
       "END IF;",
     "END; $$;"