Skip to content

Commit b4810b9

Browse files
committed
bug: correct job update polling
current polling procedure skips every second job update, due to wrong changeIndex comparison
1 parent 34da993 commit b4810b9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

command/jobs/base.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ func (f *FirehoseBase) watch(w WatchJobListFunc) {
129129

130130
// Iterate jobs and find events that have changed since last run
131131
for _, job := range jobs {
132-
if job.ModifyIndex <= f.lastChangeIndex {
132+
if job.ModifyIndex < newMax {
133133
continue
134134
}
135135

0 commit comments

Comments
 (0)