Skip to content

fix: join_queue implementation for compatibility with gevent 25.4.1 - #699

Merged
LincolnPuzey merged 3 commits into
masterfrom
fix/gevent-25.4.1
Apr 28, 2025
Merged

fix: join_queue implementation for compatibility with gevent 25.4.1#699
LincolnPuzey merged 3 commits into
masterfrom
fix/gevent-25.4.1

Conversation

@synweap15

Copy link
Copy Markdown
Collaborator

Fixes compatibility issues with gevent 25.4.1, released 17th April 2025. See gevent/gevent#2099

The issue caused dramatiq's gevent test suite to fail.

@karolinepauls

karolinepauls commented Apr 24, 2025

Copy link
Copy Markdown
Collaborator

This function is only used in the StubBroker so we could theoretically make our own queue that wraps task_done and join (public queue APIs) in threading.Condition similarly to how the standard library queue does it.

Regarding the current solution, one thing I can think of is naming the thread to make someone's debugging easier.

@synweap15

Copy link
Copy Markdown
Collaborator Author

I've added a thread name, please merge it if you approve.

@LincolnPuzey

Copy link
Copy Markdown
Collaborator

Looks reasonable to me. At least in dramatiq's own test suite, this is called with timeout=None almost all of the time, which will use the simple path.

@LincolnPuzey
LincolnPuzey merged commit 0ac2a7a into master Apr 28, 2025
@LincolnPuzey
LincolnPuzey deleted the fix/gevent-25.4.1 branch April 28, 2025 03:54
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.

3 participants