taskiq-redis
taskiq-redis copied to clipboard
taskiq-python
Broker and result backend for taskiq
The problem is that if the connection is disrupted (due to a Redis restart or temporary connectivity issues), the Taskiq worker crashes, interrupting all ongoing handlers. As a result any...
here are stack traces ``` File "/lib/python3.11/site-packages/taskiq/receiver/receiver.py", line 271, in run_task returned = await target_future ^^^^^^^^^^^^^^^^^^^ File "tasks.py", line 186, in start_new_user_data_sync await sync_data.kiq(**{ File "/lib/python3.11/site-packages/taskiq/decor.py", line 99, in kiq...
As you all probably know, Redis has changed its license, giving major corporations and contributors all the incentive to make a move to Linux Foundation's new project Valkey. So far...
I observed that taskiq-redis requires a redis client with version greater than 5 or more, is it possible to support redis clients with version 4.x? In fact, for some reason...
Running into an issue where if you close a worker while it is trying to get data, it does not gracefully stop the listen command. This causes the lock to...
When running a long task, I would like to be able to pick it up if a worker gets lost, but it means I have to set an extremley long...
First off, Taskiq is a great library! Thanks so much for bringing async to distributed task queues in Python. We're running this in production and it's doing well generally. ##...
Hey! Awesome library overall, but after upgrading to version 1.0 I am facing an issue with returning pydantic Models from tasks. Due to the change [here](https://github.com/taskiq-python/taskiq-redis/pull/57/files#diff-e094d513ebcc2056e311e355ecd214725b01bf2ffe2a555635f384191704b990L115) what happens now, is...
Here is my minimal setup: ```python from taskiq_redis import ListQueueBroker, RedisAsyncResultBackend redis_async_result = RedisAsyncResultBackend( redis_url="redis://localhost:6379", ) # Or you can use PubSubBroker if you need broadcasting broker = ListQueueBroker( url="redis://localhost:6379",...
Using taskiq 0.11.7 and taskiq-redis 1.0.2, i have this deprecation warning showing up: ``` /.venv/lib/python3.10/site-packages/taskiq_redis/redis_broker.py:49: TaskiqDeprecationWarning: Setting result backend with constructor is deprecated. Please use `with_result_backend` instead. ``` The code...
