Skip to content

Commit a7c41bc

Browse files
committed
Fix fired trigger rollback
1 parent d69ca8a commit a7c41bc

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

rolling-shutter/keyperimpl/shutterservice/triggerprocessor.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -138,9 +138,9 @@ func (tp *TriggerProcessor) ProcessEvents(ctx context.Context, tx pgx.Tx, events
138138

139139
func (tp *TriggerProcessor) RollbackEvents(ctx context.Context, tx pgx.Tx, toBlock int64) error {
140140
queries := database.New(tx)
141-
err := queries.DeleteEventTriggerRegisteredEventsFromBlockNumber(ctx, toBlock+1)
141+
err := queries.DeleteFiredTriggersFromBlockNumber(ctx, toBlock+1)
142142
if err != nil {
143-
return fmt.Errorf("failed to delete event trigger registered events from block number: %w", err)
143+
return fmt.Errorf("failed to delete fired triggers from block number: %w", err)
144144
}
145145
return nil
146146
}

0 commit comments

Comments
 (0)