somnam

Results 6 comments of somnam

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

Does anyone have an idea how these duplicated messages get created? I tried debugging the dramatiq `worker.py` and `redis.py` modules and can't seem to find the reason why (as I...

[BUG] mypy 1.12 and 1.13 problems determining license

Is there any update on this? mypy `1.13` also seems to display the same behavior.

Error when creating a topic using aiokafka 0.11.0

Added a PR for this https://github.com/faust-streaming/faust/pull/631, can someone have a look?

Question: Delayed retry queue implementation in Faust?

Hi @wbarnha and thanks very much for the message! I've tested the presented solution and it doesn't seem to work as intended. When the `@app.timer` interval kicks in there's some...

complete: keep pum visible when pressing <BS> for `complete()`

Bumped into this recently too. Looking at other completion plugins, they seem to handle `` in the provided omnifunc by returning a list of matches and delegating the handling to...

To handle partition drop when Partition table has FK

Bumped into the same issue. This seems to block from using pg_partman on partitioned tables with FK references when having `retention_keep_table = false` set. Trying to drop a partitioned table...