diff --git a/settlement/dymension/dymension.go b/settlement/dymension/dymension.go index f5a89ac7e..386b62829 100644 --- a/settlement/dymension/dymension.go +++ b/settlement/dymension/dymension.go @@ -40,7 +40,7 @@ const ( ) const ( - eventStateUpdate = "state_update.rollapp_id='%s'" + eventStateUpdate = "state_update.rollapp_id='%s' AND state_update.status='PENDING'" eventSequencersListUpdate = "sequencers_list_update.rollapp_id='%s'" ) diff --git a/settlement/dymension/dymension_test.go b/settlement/dymension/dymension_test.go index a1a8d80fd..b3ea41b21 100644 --- a/settlement/dymension/dymension_test.go +++ b/settlement/dymension/dymension_test.go @@ -229,7 +229,7 @@ func TestPostBatch(t *testing.T) { time.Sleep(50 * time.Millisecond) if c.isBatchAcceptedHubEvent { batchAcceptedCh <- coretypes.ResultEvent{ - Query: fmt.Sprintf("state_update.rollapp_id='%s'", ""), + Query: fmt.Sprintf("state_update.rollapp_id='%s' AND state_update.status='PENDING'", ""), Events: map[string][]string{ "state_update.num_blocks": {"1"}, "state_update.start_height": {"1"},