Repository Issue Activity (beta)

#896 2.2.1 missing from docs

#894 RedisBroker treats `redis.TimeoutError` as an unexpected error instead of a connection loss

#888 StreamablePipe corrupts concurrent large writes and can stall the log watcher

#827 Support/Mitigate RabbitMQ `consumer_timeout` behavior

#187 RabbitMQ Server shutdown leads to exception logged in dramatiq

#882 True sub-process restart support

#870 Redis Streams Broker

#445 Uncaught TimeLimitExceeded exception leads to a worker hanging due to decrease of alive threads

#845 Using `PyThreadState_SetAsyncExc` possibly causes deadlocks in downstream applications

#850 Messages get stuck in in-memory work_queue

#862 Support redis-py 8.x

#324 Feature: Consider abstracting Task Registry from Broker

#431 Delayed messages are being duplicated on work queue which leads to one message being consumed and processed by many WorkerThreads

#103 Feature request: create pipeline of groups

#649 Dramatiq uses more RabbitMQ connections than necessary

#848 PickleEncoder: unrestricted pickle.loads enables RCE via broker message injection

#832 RabbitMQ missing queue re-declaring does not work

#752 Improve typing of generics

#499 Namespacing not used for RedisBackend results storage

#844 Improve typing for composition module

#819 Separate exceptions logging and retries configuration

#843 Messages retry indefinitely when max_retries is None and retry_when is None

#676 Example of using actors from different files

#840 StubBroker flush_all breaks all declared consumers dead letter queues

#805 Inconsistent arguments for `perform()`