Pavel Kirilin
Pavel Kirilin
Yes! You're totally right. We'll fix it.
Generally acknowledgements are only for delivery. Means that once the message is delivered, it should be acknowledged. For error handling another mechanism should be used. For example retry middleware.
Please fix lints and tests before the review.
Yes, because you only start brokers for `broker:broker`, which happens to be `RedisStreamBroker`. In order to fix it, you can start another process that will use nats broker by starting...
It should not receive any tasks, because tasks you were sending asigned to different brokers. And they are sent in respected brokers only. If you want to send it to...
I'm not sure that it's good to use such an outdated version of the library. Right now we don't have plans to support redis `4.x` and recently upgraded our underlying...
Actually scyllapy supports connecting to AWS keyspaces already. Because we were using it with keyspaces. The scylla class has parameters `ssl_cert`, `ssl_key`, `ssl_ca_file` and `ssl_verify_mode`. To connect it to AWS...
I see now. Yes, this thing is not yet possible. We might try implementing it after we update the whole library. Because currently it needs a lot of rewrite since...
Can you pelase show how you declare tasks?
It seems like you mark your class methods as tasks. I tried this and it worked. ```python import asyncio import time from taskiq_redis import RedisStreamBroker broker = RedisStreamBroker("redis://localhost") class TaskClass:...