Skip to content

Commit

Permalink
fix: bug when relayer fails if query id is not removed yet from queri…
Browse files Browse the repository at this point in the history
…es memory
  • Loading branch information
NeverHappened committed Mar 11, 2024
1 parent 052e635 commit d3125e7
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion internal/subscriber/subscriber.go
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,8 @@ func (s *Subscriber) processUpdateEvent(ctx context.Context, event tmtypes.Resul
// Load all information about the neutronQuery directly from Neutron.
neutronQuery, err := s.getNeutronRegisteredQuery(ctx, queryID)
if err != nil {
return fmt.Errorf("failed to getNeutronRegisteredQuery: %w", err)
s.logger.Debug("Skipping query (could not find by id, probably removed)", zap.String("queryId", queryID))
continue
}

if !s.isWatchedMsgType(neutronQuery.QueryType) {
Expand Down

0 comments on commit d3125e7

Please sign in to comment.