taskiq
taskiq copied to clipboard
taskiq-python
Distributed task queue with full async support
use case ```[python] @broker.task() @validate_call() async def task(arg1: str) -> None: ... ``` so, the thing is that pydantic's `validator_call` is syncronious decorator which returns awaitable future after call right...
Hello! I have studied the documentation and have not found a way to set a global time offset for the scheduler I only found a point offset for a specific...
I am getting the following error since upgrading to 11.5 The Pydantic package does not like the TaskProgress type in the progress tracker. The types were [discussed in this PR](https://github.com/taskiq-python/taskiq/pull/130)...
hello guys, recently I came up with this exception. Seems like the problem is something already known on the internet, at least for the Celery world. The way to solve...
I'm using taskiq_redis to distribute the tasks to multiple gpus. I wanna know if all the tasks are completed or not. Please let me know how I can this info....
taskiq_demo.py如下 ```python import asyncio from taskiq_redis import ListQueueBroker, RedisAsyncResultBackend redis_dsn = 'xxxx' broker = ListQueueBroker(redis_dsn, queue_name='taskiq:req').with_result_backend( RedisAsyncResultBackend(redis_dsn) ) @broker.task async def add_one(value: int) -> int: print(value, '#' * 20) return...
 I am using ListQueueBroker from taskiq-redis. The task I am running handles database queries with Python SqlAlchemy (Postgresql). The same task when running in the background...
Today I decide to dive into taskiq and take some issue for resolving. When I set up local environment I meet problems with command: ```bash pytest ``` in `Tesing` section,...
Hi, This is the second patch I would like to introduce. Previously, we overrode the `startup` and `shutdown` to ensure both `client` and `worker` events would be handled properly. However,...
Metadata
Owner
Metadata
Distributed task queue with full async support