Skip to content

v1.11.0
Compare
Choose a tag to compare
@Bogdanp Bogdanp released this 22 May 07:04
· 228 commits to master since this release
v1.11.0
2f44ff6
This commit was signed with the committer’s verified signature.
Bogdanp Bogdan Popa
GPG key ID: 4227ABAD6F9D03D5
Verified
Learn about vigilant mode.

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)
Assets 2
Loading