make sure we always at least poll once on the latest unprocessed id

threefoldtech · May 6, 2020 · 84a6855 · 84a6855
1 parent bdf9fbe
commit 84a6855
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/provision/source.go b/pkg/provision/source.go
@@ -77,7 +77,12 @@ func (s *pollSource) Reservations(ctx context.Context) <-chan *Reservation {
 				continue
 			}
 
-			next = lastID + 1
+			// guard to make sure we always at least poll once on the latest unprocessed id
+			if len(res) == 0 {
+				next = lastID
+			} else {
+				next = lastID + 1
+			}
 
 			select {
 			case <-ctx.Done():