diff --git a/src/mappings/bank/balanceChange.ts b/src/mappings/bank/balanceChange.ts
index 68eae0174..3a1fb49db 100644
--- a/src/mappings/bank/balanceChange.ts
+++ b/src/mappings/bank/balanceChange.ts
@@ -37,7 +37,7 @@ export async function handleNativeBalanceDecrement(event: CosmosEvent): Promise<
 }
 
 export async function handleNativeBalanceIncrement(event: CosmosEvent): Promise<void> {
-  await attemptHandling(event, _handleNativeBalanceDecrement, unprocessedEventHandler);
+  await attemptHandling(event, _handleNativeBalanceIncrement, unprocessedEventHandler);
 }
 
 async function _handleNativeBalanceDecrement(event: CosmosEvent): Promise<void> {
diff --git a/tests/e2e/entities/test_native_balances.py b/tests/e2e/entities/test_native_balances.py
index 294252533..02815a4de 100644
--- a/tests/e2e/entities/test_native_balances.py
+++ b/tests/e2e/entities/test_native_balances.py
@@ -79,7 +79,7 @@ def test_account_balance_tracking_query(self):
             query {
                 nativeBalanceChanges{
                     groupedAggregates(groupBy: [ACCOUNT_ID, DENOM]){
-                        sum{ 
+                        sum{
                             balanceOffset
                         }
                         keys
@@ -125,8 +125,9 @@ def filtered_native_balance_query(_filter, order=""):
                 delegator_balance += int(balance["sum"]["balanceOffset"])
             else:
                 self.fail("couldn't find validator or delegator address in keys")
-        self.assertLessEqual(validator_balance, -7 * 10 ** 18)
-        self.assertLessEqual(delegator_balance, 7 * 10 ** 18)
+
+        self.assertEqual(validator_balance, -7000000000000092000)
+        self.assertEqual(delegator_balance, 6999999999999908000)
 
         for (name, query, orderAssert) in (
             (