Skip to content

Conversation

@ambv
Copy link
Contributor

@ambv ambv commented Feb 14, 2018

The implementation is a bit convoluted with contexts and all but in the end multiprocessing.queues is a valid module that is importable and usable. Fixing this removes a bunch of false positives around this.

Also, introduced other queue variants.

# It's marked as such to be able to use the generic Queue in __init__.pyi.
def __init__(self, maxsize: int = ..., *, ctx: Any = ...) -> None: ...
def get(self, block: bool = ..., timeout: Optional[float] = ...) -> _T: ...
def put(self, item: _T, block: bool = ..., timeout: Optional[float] = ...) -> None: ...
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The argument is actually called obj in the code.

@JelleZijlstra JelleZijlstra merged commit 18ae67d into master Feb 17, 2018
@JelleZijlstra JelleZijlstra deleted the multiprocessing.queues branch February 17, 2018 01:00
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