Bogdanp/dramatiq issues and pull requests

#582 - feature(redis): Dequeue a single message

Pull Request - State: closed - Opened by theilgaard over 1 year ago - 1 comment

#581 - New release

Issue - State: closed - Opened by davidt99 over 1 year ago - 2 comments

#580 - Add an actor decorator argument to compute backoff time using a function

Issue - State: open - Opened by arseniiarsenii over 1 year ago - 3 comments

#579 - docs: add missing docstring for Broker.join() function

Pull Request - State: closed - Opened by jenstroeger over 1 year ago - 1 comment

#578 - Dramatiq workers hangs very often, no logs were seen in logs even if it is verbose mode.

Issue - State: open - Opened by Harinib-Kore over 1 year ago - 12 comments

#577 - fix: don’t hardcode the temp path for the Prometheus middleware

Pull Request - State: closed - Opened by jenstroeger over 1 year ago

#576 - Inconsistent `/tmp` path setup for Prometheus middleware.

Issue - State: closed - Opened by jenstroeger over 1 year ago - 1 comment

#575 - Improve typing for Results Backend.

Issue - State: open - Opened by jenstroeger over 1 year ago - 4 comments

#574 - Having bizarre issues with custom pytest fixture

Issue - State: open - Opened by dragonpaw over 1 year ago

#573 - doc: add members documentation to Result middleware, and Results and Rate Limiters backends

Pull Request - State: closed - Opened by jenstroeger over 1 year ago

#572 - doc: add missing Raises to the group.wait()

Pull Request - State: closed - Opened by jenstroeger over 1 year ago - 1 comment

#571 - Missing OpenTelemetry instrumentation

Issue - State: closed - Opened by staticdev over 1 year ago - 8 comments

#570 - doc: minor improvements of Cookbook and Reference doc pages

Pull Request - State: closed - Opened by jenstroeger over 1 year ago - 1 comment

#569 - Add support for timedelta as actor delay

Pull Request - State: closed - Opened by h3nnn4n over 1 year ago - 1 comment

#568 - Feature: add a TailMessage middleware

Issue - State: closed - Opened by jenstroeger over 1 year ago - 1 comment

#567 - Support redis-py 5

Pull Request - State: closed - Opened by scott-8 over 1 year ago

#566 - doc: mention return value for group.run() methods

Pull Request - State: closed - Opened by jenstroeger over 1 year ago - 3 comments

#565 - Could really use at least one realistic, full-blown example in the docs

Issue - State: closed - Opened by nathan-mill over 1 year ago - 7 comments

#564 - Result retrieval from groups/pipelines only work for the default broker

Issue - State: closed - Opened by DiegoPomares over 1 year ago - 1 comment

#563 - Use backend from group/pipeline broker in get_result(s)

Pull Request - State: closed - Opened by DiegoPomares over 1 year ago - 1 comment

#562 - Improved legibility of the help parameter for --processes

Pull Request - State: closed - Opened by santigandolfo over 1 year ago - 2 comments

#561 - chore: add type hint to global dramatiq.broker.global_broker variable

Pull Request - State: closed - Opened by jenstroeger over 1 year ago - 1 comment

#560 - Logs are no longer being written, and it's unable to receive task information from the server.

Issue - State: open - Opened by zhugexinxin over 1 year ago

#559 - Duplicated log Filter when closing RabbitmqBroker many times

Issue - State: open - Opened by gagtomm1 over 1 year ago
Labels: bug, beginner friendly

#558 - OSError: [Errno 98] Address already in use when calling send function

Issue - State: open - Opened by heatherKoo07 over 1 year ago - 9 comments

#557 - Actor arguments do not get freed from memory

Issue - State: closed - Opened by akshhack over 1 year ago - 1 comment

#556 - fix: detect the missing of rabbitmq queue and redeclare it.

Pull Request - State: closed - Opened by JetDrag over 1 year ago - 12 comments

#555 - Type issue: statements become unreachable when using `global_broker`

Issue - State: closed - Opened by jenstroeger over 1 year ago - 1 comment

#554 - doc: update link to example grafana dashboard

Pull Request - State: closed - Opened by jvllmr over 1 year ago - 1 comment

#553 - broker_priority not work

Issue - State: open - Opened by notwhy over 1 year ago - 3 comments

#552 - Don't reload on watchdog 'opened' events

Pull Request - State: closed - Opened by seanpile over 1 year ago - 1 comment

#551 - Don't block on get

Pull Request - State: closed - Opened by nkgilley over 1 year ago

#550 - funboost + dramatiq is very nice

Issue - State: closed - Opened by ydf0509 almost 2 years ago - 1 comment

#549 - build: add missing asyncio module to package

Pull Request - State: closed - Opened by scabala almost 2 years ago - 4 comments

#548 - Results are automatically deleted after 10 minutes

Issue - State: closed - Opened by Eldellano almost 2 years ago - 1 comment

#547 - Add 3rd-party reference for cron tasks

Pull Request - State: closed - Opened by codingjoe almost 2 years ago

#546 - Ensure only canonical are added to RabbitmqBroker.queues

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

#545 - Mark message as failed when fail to process

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

#544 - Fix “an interrupted (Cancelled) coroutine doesn't cleanup”

Pull Request - State: closed - Opened by caspervdw almost 2 years ago - 4 comments

#543 - The error while launching the worker with a callable setup.

Issue - State: closed - Opened by 4l1fe almost 2 years ago - 1 comment

#542 - [DQ-540] Adding a work queue model with 10 workers to prevent an unlimited amount of connections being open

Pull Request - State: closed - Opened by ujnamss almost 2 years ago

#541 - unittest failing

Issue - State: closed - Opened by manjusfi almost 2 years ago - 1 comment

#540 - Need to limit the number of TCP connections when invoking actor.send

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

#539 - How should I colorize my log output

Issue - State: closed - Opened by dream2333 almost 2 years ago - 1 comment

#538 - message: add namedtuple methods for backwards-compat

Pull Request - State: closed - Opened by Bogdanp almost 2 years ago

#537 - Return intermediary results from longer running tasks

Issue - State: closed - Opened by jorenretel almost 2 years ago - 1 comment

#536 - Support asynchronous (asyncio) contexts in actors

Pull Request - State: closed - Opened by caspervdw almost 2 years ago - 12 comments

#535 - Beginners ask for help

Issue - State: closed - Opened by singdoo almost 2 years ago - 1 comment

#534 - [Question] Actors comunication

Issue - State: closed - Opened by Jonatha-Varjao almost 2 years ago - 1 comment

#533 - [WIP] Postgres backend results

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

#532 - Add a release GHA workflow using 'build'

Pull Request - State: closed - Opened by sirosen almost 2 years ago - 1 comment

#531 - py.typed file is not present in built distributions on pypi

Issue - State: closed - Opened by sirosen almost 2 years ago - 9 comments

#530 - Missing 1.14 release on github

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

#529 - StubBroker problems with Prometheus middleware.

Issue - State: open - Opened by jenstroeger about 2 years ago - 1 comment

#528 - recommended way to execute async functions inside dramatiq actors

Issue - State: closed - Opened by Star3Lord about 2 years ago - 5 comments

#527 - Delayed Jobs aren't run after cycling Redis

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

#526 - TypeError: PickleEncoder.encode() missing 1 required positional argument: 'data'

Issue - State: closed - Opened by jeffery9876 about 2 years ago - 1 comment

#525 - RuntimeError: Watching for source changes is not supported on win32

Issue - State: closed - Opened by zfei about 2 years ago - 5 comments

#524 - dramatiq.composition.pipeline is not working as expected with reference to the documentation.

Issue - State: open - Opened by priyanshu-mayank-tech about 2 years ago - 4 comments

#523 - [DQ-520] Fixes port usage problem when thousands of threads are created

Pull Request - State: closed - Opened by ujnamss about 2 years ago - 1 comment

#522 - FeatReq: Support timedelta for delays?

Issue - State: closed - Opened by dragonpaw about 2 years ago - 4 comments
Labels: polar

#521 - FeatReq: Typehints in dramatiq.middleware

Issue - State: open - Opened by dragonpaw about 2 years ago - 3 comments

#520 - Run out of ports when 65000+ messages are sent via 65000+ threads

Issue - State: closed - Opened by manjusfi about 2 years ago - 6 comments

#519 - Discussion: Resque-like priority queues

Issue - State: open - Opened by h3nnn4n about 2 years ago - 1 comment

#518 - How to make Dramatiq return a GUID when send() so the result can be retrived later by async polling?

Issue - State: closed - Opened by staticdev about 2 years ago - 1 comment

#517 - feature request: Retries middleware to set max_retries as an option

Issue - State: open - Opened by giuppep about 2 years ago - 1 comment

#516 - Fix tests broken by moving Message to dataclass

Pull Request - State: closed - Opened by orsinium about 2 years ago - 1 comment

#515 - Use ParamSpec to type check Actor args

Pull Request - State: closed - Opened by orsinium about 2 years ago

#514 - New release, please!

Issue - State: closed - Opened by anton-petrov about 2 years ago - 6 comments

#513 - Make Message Generic of result

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

#512 - Annotate types for Actor and Message

Pull Request - State: closed - Opened by orsinium about 2 years ago - 1 comment

#511 - Add python3.11 build support, drop python3.6

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

#510 - request: better documentation on what error codes mean

Issue - State: closed - Opened by iwishiwasaneagle over 2 years ago - 1 comment

#509 - Python 3.10 and Python 3.11 build support

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

#508 - Priority doesn't seem to behave as expected

Issue - State: open - Opened by George3d6 over 2 years ago

#507 - RabbitMQ broker doesn't seem to retry publishing on SSL socket errors

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

#506 - fix: Avoid warning on missing dependencies when those dependencies are used.

Pull Request - State: closed - Opened by DanCardin over 2 years ago - 4 comments

#505 - All workers terminate when one worker crashes

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

#504 - Worker randomly crashes while idle in k8s

Issue - State: closed - Opened by vfronterotta over 2 years ago - 2 comments
Labels: needs investigation

#503 - Fix typo

Pull Request - State: closed - Opened by byrman over 2 years ago - 1 comment

#502 - docs: Fix a few typos

Pull Request - State: closed - Opened by timgates42 over 2 years ago

#501 - Why do you reverse middleware list in emit_after method?

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

#500 - Misleading get_result timeout in documentation

Issue - State: closed - Opened by mrtolkien over 2 years ago

#499 - Namespacing not used for RedisBackend results storage

Issue - State: open - Opened by coandco over 2 years ago

#498 - update motivation.md - RQ supports task prio

Pull Request - State: closed - Opened by cmflynn over 2 years ago

#497 - Actors with at-most-once delivery

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

#496 - fix docs

Pull Request - State: closed - Opened by angus-pearson over 2 years ago

#495 - Question: why we use "build_message_key" instead of "message_id"

Issue - State: closed - Opened by academe-01 over 2 years ago - 1 comment

#494 - How-to specify actors default options

Issue - State: closed - Opened by academe-01 over 2 years ago - 2 comments

#493 - Changelog missing for latest version

Issue - State: closed - Opened by kviktor over 2 years ago - 1 comment

#492 - Use scan instead of keys in redis lua script

Pull Request - State: closed - Opened by Stealthmate over 2 years ago - 3 comments

#491 - Use SCAN or the like instead of KEYS

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

#490 - Modify loop behavior

Pull Request - State: closed - Opened by brianseodd over 2 years ago

#489 - Seems like dramatiq works as LIFO or with random instead of broker FIFO principle

Issue - State: closed - Opened by rive-n almost 3 years ago - 2 comments

#488 - Emit signal before call dramatiq.Consumer.consume

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

#487 - ci: bump windows to 2019

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

#486 - Fallback to Redis if RabbitMQ deps aren't installed

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

#485 - Fix an incorrect type annotation

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

#484 - Fix a typo

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

#483 - Video intro on frontpage cannot be followed using [redis]

Issue - State: closed - Opened by kurtmckee almost 3 years ago - 2 comments

GitHub / Bogdanp/dramatiq issues and pull requests