taskiq icon indicating copy to clipboard operation
taskiq copied to clipboard

Distributed task queue with full async support

Results 124 taskiq issues
Sort by recently updated
recently updated
newest added

### Discussed in https://github.com/orgs/taskiq-python/discussions/370 Originally posted by **febus982** October 8, 2024 Having tracing, metrics and logs supported for OpenTelemetry would be a great addition.

### Env python: 3.12.3 os: window 10 taskiq: 0.11.10 ### Q I want to limit the concurrent execution of tasks in the broker, so I set sync_tasks_pool_size=1 and max_async_tasks=1, but...

I am using rabbitmq with taskiq, My use case is to delay a job and inside the task worker i am using context to requeue the job , There its...

Version 0.11.7 is the last working release for this code. ```python from taskiq import TaskiqScheduler, ZeroMQBroker from taskiq.schedule_sources import LabelScheduleSource broker = ZeroMQBroker() scheduler = TaskiqScheduler( broker=broker, sources=[LabelScheduleSource(broker)], ) @broker.task(schedule=[{"cron":...

Hello team, in my project there's a relatively large amount of tasks, therefore I decided to split them into separate files. This works reasonably well, as soon as I start...

There are many workflows that require interweaving async and non async (CPU intensive) blocking code. These cannot each be split up into separate tasks because there are locally stored files...

Prometheus is good, but it uses file operations on each middleware hook; that might become a bottleneck. Suggested middleware uses similar metrics, but it keeps statistics in memory and may...

### Issue: Dependency Context Not Propagating to Broker in Task Execution #### Problem Description I'm using a `fastapi_app` fixture along with `InMemoryBroker` and `InmemoryResultBackend` from `taskiq`. The setup works well...

the worker reises an error. I guess the root cause came when the connection with RabbitMQ terminated or was lost. No exception was found before or after this error. Unfortunately,...