Latest version: v0.13.1

PyUp actively tracks 462,628 Python packages for vulnerabilities to keep your Python environments secure.

Scan your dependencies

Page 1 of 11


- Finetune to ``multiprocessing.ServerProcess`` and its shared-memory facilities.
- Fix a bug in ``mpserver.{Server, AsyncServer}`` related to input buffer.
- Increases ``timeout`` parameter default to 600 in ``mpserver.{Server, AsyncServer}.stream``.
- Finetune ``mpserver.{Server, AsyncServer}`` internals.


- Breaking changes to ``mpserver.Server`` API: the class is split into two classes: ``Server`` and ``AsyncServer``.
- ```` got new parameter ``backpressure`` (previously only the async call has this parameter).
- Finetuned waiting and sleeping logic in ``mpserver.{Server, AsyncServer}``; use ``Condition`` to replace sleeping.
- Made sure (or confirmed) that ```` and ``` are thread-safe.
- ``streamer.Stream.peek`` finetune of printing; got new parameter ``prefix`` and ``suffix``.
- Refinements to classes ``streamer.{IterQueue, IterProcessQueue, AsyncIterQueue}``.
- Refinements to ``multiprocessing.ServerProcess``: further diverge from the standard class.
- Initial support for "shared memory" in the class ``multiprocessing.ServerProcess``.


- New function ``streamer.tee``.
- New class ``streamer.IterProcessQueue``.
- Removed the "cancellation" "Event" mechanism in ``mpserver.Server`` that was introduced in 0.12.7.
There are two main reasons for the removal: (1) the ``multiprocessing.manager.Event`` that is checked
by every worker seems to have considerable overhead although I did not measure it; (2) there is
difficulty in maintaining a reference to the ``Event`` object in the event of cancellation to
ensure any worker that tries to access it will do so before it is gone in the manager process;
this issue manifests as ``KeyError`` during unpickling when the object is being retrieved from
a multiprocessing queue.


- Removed ``mpserver.{ProcessWorker, ThreadWorker}``; just use ``Worker``.
- Renamed ``mpserver.make_threadworker`` to ``mpserver.make_worker``.
- ``mpserver.Server`` got new method ``async_stream``.
- New classes ``streamer.IterQueue``, ``streamer.AsyncIterQueue``.
- Minor tuning of ``multiprocessing.ServerProcess``.



- Methods ``streamer.Stream.{async_parmap, parmap_async}`` are dropped and merged into ``parmap``.
- Function ``http.run_app``.


- ``streamer.Stream.parmap``: parameter ``executor`` became named only.
- ``multiprocessing.Manager`` was renamed ``ServerProcess``.
- Parameter ``backlog`` to ``mpserver.Server.__init__`` was renamed to ``capacity``.


- ``streamer.Stream`` added extensive support for async.
- Methods ``streamer.Stream.{to_sync, to_async, __aiter__}``.
- Method ``mpserver.Server.full`` and properties ``mpserver.Server.{capacity, backlog}``.
- Added capabilities to cancel a item submitted to ``mpserver.Server`` and halt its processing in the pipeline as soon as practical.
- Made ``mpservice.multiprocessing`` more close to the standard ``multiprocessing`` in terms of what can be imported from it.
- New parameter ``name`` to ``SpawnContext.Manager``.
- ``SpawnProcess`` captures warnings to logging.



- New method ``streamer.Stream.async_parmap`` with corresponding class ``AsyncParmapper``.


- The cleanup or "finalize" logic of ``streamer.{Buffer, Parmapper, AsyncParmapper, ParmapperAsync}``.

Page 1 of 11