We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3582c45 commit 24845a0Copy full SHA for 24845a0
1 file changed
core/src/worker/workflow/wft_poller.rs
@@ -121,7 +121,11 @@ impl WFTPollerShared {
121
}
122
123
124
- // If there's no sticky backlog, balance poller counts
+ // If there's no sticky backlog, balance poller counts. This logic allows the poller
125
+ // to proceed if it has the same or fewer pollers as it's opposite. There is a preference
126
+ // for the sticky poller when counts are equal. This does not mean we always have equal
127
+ // numbers of pollers, as later on the scaler will also prevent polling based on the scaling
128
+ // information provided independently by the sticky/nonsticky queues.
129
if *self.last_seen_sticky_backlog.0.borrow() == 0 {
130
if let Some((sticky_active, non_sticky_active)) =
131
self.sticky_active.get().zip(self.non_sticky_active.get())
0 commit comments