Bogdanp/dramatiq issues and pull requests

#482 - typing: improved mypy support

Pull Request - State: closed - Opened by staticdev almost 3 years ago - 3 comments

#481 - fix: race condition on join() in the redis broker.

Pull Request - State: closed - Opened by CaselIT almost 3 years ago - 14 comments

#480 - Race condition in redis broker `join`

Issue - State: closed - Opened by CaselIT almost 3 years ago

#479 - send_with_options with delay seems not right

Issue - State: closed - Opened by heyhpython almost 3 years ago - 1 comment

#478 - build: drop Python 3.6

Pull Request - State: closed - Opened by staticdev almost 3 years ago - 4 comments

#477 - Drop Python 3.6

Issue - State: closed - Opened by staticdev almost 3 years ago

#476 - add GitHub URL for PyPi

Pull Request - State: closed - Opened by andriyor almost 3 years ago - 1 comment

#475 - Correct Contributor Name

Pull Request - State: closed - Opened by hopeman15 about 3 years ago - 1 comment

#473 - add GeventRabbitmqBroker

Pull Request - State: closed - Opened by horpto about 3 years ago - 2 comments

#472 - [Discussion] Dynamic queues

Issue - State: closed - Opened by jairhenrique about 3 years ago

#470 - Add guard clause to stub.py

Pull Request - State: closed - Opened by KentBeck about 3 years ago - 7 comments

#469 - How to mute exception errors for a task that will be retried?

Issue - State: open - Opened by mparent61 about 3 years ago - 6 comments

#468 - Worker restarts automatically

Issue - State: closed - Opened by tlmn-local about 3 years ago - 7 comments

#459 - AttributeError when consuming using Redis broker

Issue - State: closed - Opened by tiwilliam about 3 years ago - 3 comments

#451 - Disable unfinished tasks autorestart on dramatiq startup?

Issue - State: closed - Opened by neurocker over 3 years ago - 2 comments

#449 - Stuff SkipMessage and fail skipped messages

Pull Request - State: closed - Opened by FinnLidbetter over 3 years ago

#444 - redis: only requeue existing messages for dead workers

Pull Request - State: closed - Opened by Bogdanp over 3 years ago - 1 comment

#442 - Bug: Worker gets stuck working on a task indefinitely since 1.12.0

Issue - State: closed - Opened by sarnikowski over 3 years ago - 6 comments

#440 - Skipped messages can get inconsistent results stored

Issue - State: closed - Opened by FinnLidbetter over 3 years ago - 8 comments

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

Issue - State: open - Opened by somnam over 3 years ago - 4 comments
Labels: polar

#424 - Actor priority ignored

Issue - State: open - Opened by mihasajko over 3 years ago - 4 comments

#421 - Warnings emitted for unused result backend

Issue - State: closed - Opened by DanCardin over 3 years ago - 2 comments

#410 - Maximum recursion depth exceeded while encoding a JSON object for a long pipeline

Issue - State: closed - Opened by synweap15 over 3 years ago - 3 comments

#400 - [Class based actor]: options defined in `Meta` does not work as expected

Issue - State: closed - Opened by lnever almost 4 years ago - 4 comments

#399 - in memory broker: how to use?

Issue - State: closed - Opened by bitsofinfo almost 4 years ago - 3 comments

#392 - How to disable prefetching

Issue - State: closed - Opened by hmoravec almost 4 years ago - 3 comments

#391 - [CRITICAL] Consumer encountered an unexpected error [rabbitmq]

Issue - State: closed - Opened by anapaulagomes almost 4 years ago - 2 comments

#381 - RabbitmqBroker open fd leak with gunicorn and gevent

Issue - State: closed - Opened by gdvalle about 4 years ago - 7 comments
Labels: needs investigation

#355 - core: clear failed messages' exceptions except for StubBroker

Pull Request - State: closed - Opened by Bogdanp over 4 years ago - 1 comment

#345 - Remove Prometheus from the list of default middleware

Issue - State: open - Opened by CaselIT over 4 years ago - 4 comments
Labels: enhancement

#324 - Feature: Consider abstracting Task Registry from Broker

Issue - State: open - Opened by funkybob over 4 years ago - 5 comments
Labels: enhancement, polar

#322 - Feature request: Kafka support

Issue - State: closed - Opened by antonrh over 4 years ago - 2 comments

#309 - Dramatiq globally opens port 9191 !!!

Issue - State: closed - Opened by tenuki almost 5 years ago - 3 comments

#306 - WIP: adds types for user facing API

Pull Request - State: closed - Opened by sobolevn almost 5 years ago - 12 comments

#305 - Typing support for the public API

Issue - State: closed - Opened by sobolevn almost 5 years ago - 6 comments
Labels: enhancement

#298 - feat(rabbitmq): add mandatory flag option

Pull Request - State: closed - Opened by davidt99 almost 5 years ago - 2 comments

#280 - OSError: [Errno 98] Address already in use exception when running multiple dramatiq processes

Issue - State: closed - Opened by yurayakimenko almost 5 years ago - 2 comments

#266 - [CRITICAL] Consumer encountered an unexpected error, AttributeError: 'NoneType' object has no attribute 'decode'

Issue - State: closed - Opened by vkatochka about 5 years ago - 21 comments
Labels: needs investigation

#258 - [Redis broker] Error "user_script:90: too many results to unpack" causes worker to sit idle forever

Issue - State: closed - Opened by benekastah about 5 years ago - 5 comments
Labels: bug

#253 - 'Prometheus' object has no attribute 'total_retried_messages'

Issue - State: closed - Opened by metheoryt about 5 years ago - 3 comments
Labels: needs investigation

#213 - Retries middleware options are ignored if task receives SIGKILL or equivalent while running

Issue - State: closed - Opened by MihaiBalint almost 6 years ago - 4 comments

#211 - Should TimeLimit middleware restart hanging thread instead of stopping?

Issue - State: closed - Opened by metheoryt almost 6 years ago - 3 comments
Labels: needs investigation

#150 - feat(composition): add support for group completion callbacks

Pull Request - State: closed - Opened by Bogdanp about 6 years ago - 4 comments

#147 - rate limiting using redis backend error

Issue - State: closed - Opened by weiztech about 6 years ago - 10 comments

#121 - Lazy rmq broker

Pull Request - State: closed - Opened by mehdigmira over 6 years ago

#103 - Feature request: create pipeline of groups

Issue - State: open - Opened by AndreaOrru over 6 years ago - 20 comments
Labels: enhancement, polar

#85 - Getting dramatiq.errors.ConnectionClosed when using example code from website

Issue - State: closed - Opened by kiorq almost 7 years ago - 3 comments

#57 - Handling task failures+retries during testing

Issue - State: closed - Opened by rpkilby almost 7 years ago - 13 comments
Labels: enhancement

#46 - Dramatiq probably doesn't do at-least-once delivery

Issue - State: closed - Opened by aphyr almost 7 years ago - 3 comments
Labels: enhancement

#45 - A license related recommendation/query

Issue - State: closed - Opened by unexceptable almost 7 years ago - 5 comments

#9 - Class-based actor

Issue - State: closed - Opened by rakanalh over 7 years ago - 17 comments
Labels: enhancement

GitHub / Bogdanp/dramatiq issues and pull requests