Skip to content

Commit

Permalink
Added comment
Browse files Browse the repository at this point in the history
  • Loading branch information
kidambisrinivas committed Sep 30, 2024
1 parent 17b6c1a commit 2786cef
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions core/capabilities/triggers/logevent/trigger.go
Original file line number Diff line number Diff line change
Expand Up @@ -152,6 +152,10 @@ func (l *logEventTrigger) Listen(ctx context.Context) {
l.lggr.Fatalw("QueryKey failure", "err", err)
continue
}
// ChainReader QueryKey API provides logs including the cursor value and not
// after the cursor value. If the response only consists of the log corresponding
// to the cursor and no log after it, then we understand that there are no new
// logs
if len(logs) == 1 && logs[0].Cursor == cursor {
l.lggr.Infow("No new logs since", "cursor", cursor)
continue
Expand Down

0 comments on commit 2786cef

Please sign in to comment.