Skip to content

Commit

Permalink
Enforce that log follower follow time is based on pollInterval
Browse files Browse the repository at this point in the history
  • Loading branch information
nocturnalastro committed Nov 16, 2023
1 parent 9c4c702 commit 7054d1c
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/collectors/log_follower.go
Original file line number Diff line number Diff line change
Expand Up @@ -223,7 +223,7 @@ func (logs *LogsCollector) poll() error {

start := time.Now()
generation := logs.lastPoll.Generation()
lines, err := processStream(stream, time.Now().Add(followDuration))
lines, err := processStream(stream, time.Now().Add(logs.GetPollInterval()))
if err != nil {
return err
}
Expand Down

0 comments on commit 7054d1c

Please sign in to comment.