Dramatiq

Added

* `dramatiq_queue_prefetch` environment variable to control the number of messages to prefetch per worker thread. (183, 184, xelhark)
* The RabbitMQ broker now retries the queue declaration process if an error occurs. (179, davidt99)
* Support for accessing nested broker instances from the CLI. (191, bersace)
* Support for eagerly raising actor exceptions in the joining thread with the `StubBroker`. (195, 203)
* Support for accessing the current message from an actor via `CurrentMessage`. (208)

Changed

* Pinned pika version `>1.0,<2.0`. (202)

Fixed

* An issue where workers would fail and never recover after the connection to Redis was severed. (207)
* ``pipe_ignore`` has been fixed to apply to the next message in line within a pipeline. (194, metheoryt)

Added

* The RabbitMQ broker now supports native message priorities. (157, davidt99)
* Support for specifying the actor class to `actor`. (169, gilbsgilbs)

Changed

* Pika 0.13 is now required.

Fixed

* Consumers are now stopped after workers finish running their tasks. (160, brownan)
* Worker logging on Python 3.7 is no longer delayed.

Fixed

* Changed license classifier to the correct license. This is why you shouldn't publish changed before you've had coffee, folks!

**This release was removed from PyPI because it had a bad license classifier (GPLv3+ instead of LGPLv3+) due to a mistake on my part.**

Fixed

* License classifier in PyPI package. There were no source code
changes for this release.

Added

* Support for redis-py 3.x. (142, maerteijn)

Fixed

* Workers wait for RMQ messages to be acked upon shutdown. (148)
* Pipelines no longer continue when a message is failed. (151, davidt99)
* Log files now work under Windows. (141, ryansm1)

This is a big one!


Added

* Barriers.

Changed

* `cli.main` now takes an optional argument namespace so that users
may define their own entrypoints. ([140], [maerteijn])
* Actor "message received" and "completed in x ms" log messages are
now logged with the `DEBUG` level instead of `INFO` level. This
improves throughput and makes logging much less verbose.
* The `TimeLimit` middleware no longer uses signals to trigger time
limit handling. Instead it uses a background thread per worker
process.
* Dramatiq now shuts itself down if any of the workers die
unexpectedly (for example, if one of them is killed by the OOM
killer).
* Windows is now supported (with some caveats)! ([119], [ryansm1])

Fixed

* Allow `pipe_ignore` option to be set at the actor level. ([100])
* Result encoder now defaults to the global encoder. ([108], [xdmiodz])
* Dot characters are now allowed in queue names. ([111])
* Tests are now run on Windows. ([113], [ryansm1])

[100]: https://github.com/Bogdanp/dramatiq/issues/100
[108]: https://github.com/Bogdanp/dramatiq/issues/108
[111]: https://github.com/Bogdanp/dramatiq/issues/111
[113]: https://github.com/Bogdanp/dramatiq/issues/113
[119]: https://github.com/Bogdanp/dramatiq/issues/119
[140]: https://github.com/Bogdanp/dramatiq/issues/140
[maerteijn]: https://github.com/maerteijn
[ryansm1]: https://github.com/ryansm1
[xdmiodz]: https://github.com/xdmiodz