Dramatiq

**Note: this version was released on 2022-04-02. I am just now backfilling a GitHub Release for it.**

Fixed

* A race condition in the Redis broker’s join method. ([480](https://github.com/Bogdanp/dramatiq/issues/480), [#481](https://github.com/Bogdanp/dramatiq/pull/481), [CaselIT](https://github.com/CaselIT))
* Skipped messages and messages failed due to [AgeLimit](https://dramatiq.io/reference.html#dramatiq.middleware.AgeLimit) now store results more consistently. ([440](https://github.com/Bogdanp/dramatiq/issues/440), [#449](https://github.com/Bogdanp/dramatiq/pull/449), [FinnLidbetter](https://github.com/FinnLidbetter))

Changed

* Typing support has been improved. ([482](https://github.com/Bogdanp/dramatiq/issues/482), [staticdev](https://github.com/staticdev))
* The default broker now falls back to Redis if the RabbitMQ extras are not installed, in an attempt to make the getting started process easier. ([483](https://github.com/Bogdanp/dramatiq/issues/483), [#486](https://github.com/Bogdanp/dramatiq/pull/486), [kurtmckee](https://github.com/kurtmckee))

Fixed

* An issue where signals remained blocked after worker process boot. (465, 466, FinnLidbetter)

Fixed

* An issue where stopping the process too quickly after boot could lead to an `AttributeError`. (463, 464, FinnLidbetter)

Fixed

* Actors and messages can now specify 0 backoff. (FinnLidbetter, 438)
* An issue where Redis message ids could be put back onto the queue after ack/nack. (442, 444)

Removed

* Dropped Python 3.5 support as it reached end-of-life.

Added

* RabbitMQ messages now have a redelivered flag. (405, nffdiogosilva)
* Time limits now work under gevent. (408, FinnLidbetter)
* Shutdown notifications now work under gevent. (426, FinnLidbetter)

Changed

* The watchdog library is no longer being pinned to a specific version. (428)
* The Redis broker now limits unpacks to half the size of the Lua stack. (433, 434, ethervoid)

Fixed

* Async exceptions now correctly set the thread id on Python 3.7 and up. (419, 420, FinnLidbetter)

Added

* `dramatiq.Message.decode` now raises a `dramatiq.DecodeError` on exception. (375, thomazthz)

Changed

* The RabbitMQ broker moves messages that fail to decode to the DLQ. (375, thomazthz)

Fixed

* The Redis broker is now more defensive in how it handles re-enqueueing messages. This should fix a potential race condition where a worker could hit its heartbeat timeout but still end up re-enqueueing messages (thus ending up with the same message id enqueued multiple times). (266, 395)
* A code path that could lead to an unbound variable error has now been fixed. (382)
* Deleting the connection off of a `RabbitMQ` broker now correctly closes it and its associated channel (if any) before removing it from the broker. (381, 384)