Skip to content

fix(workerchild): ignore empty producer future sets - #766

Merged
lvthanh03 merged 1 commit into
mainfrom
tony/fix-empty-producer-futures
Jul 27, 2026
Merged

fix(workerchild): ignore empty producer future sets#766
lvthanh03 merged 1 commit into
mainfrom
tony/fix-empty-producer-futures

Conversation

@lvthanh03

Copy link
Copy Markdown
Member

Arroyo’s FutureTrackingProducer.collect_futures() retains producer keys after clearing their queues. Taskbroker therefore treated mappings containing only empty sets as pending future work, routing subsequent tasks through the asynchronous future-completion path.

We want to check the collected sets instead of the mapping length.

@lvthanh03
lvthanh03 requested a review from a team as a code owner July 24, 2026 20:05
@lvthanh03
lvthanh03 merged commit e5bfd35 into main Jul 27, 2026
29 checks passed
@lvthanh03
lvthanh03 deleted the tony/fix-empty-producer-futures branch July 27, 2026 13:49
lvthanh03 added a commit to getsentry/sentry that referenced this pull request Jul 27, 2026
)

Rolls backpressure out to FutureTrackingProducer after the previous
attempt in #120470 and after a
bug fix was made: getsentry/taskbroker#766.

Adds an option to enable FTP backpressure, this will require producers
to restart after the option changes to take effect. Updates existing FTP
instances to use this.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants