taskiq

taskiq copied to clipboard

Bug: worker thrashing on task startup

2

Hi there, While trying to use TaskIQ in a specific scenario, waiting for a task to spin up resulted in constant thrashing (task killed and restarted in loop). After triaging...

kmc-firework

Need advice on dynamically change brokers.

1

I need advice on dynamically switching brokers. This is similar to: [https://github.com/taskiq-python/taskiq/issues/439](https://github.com/taskiq-python/taskiq/issues/439) I'm trying to support multiple brokers in my app. The idea is that I can't create a broker...

wwarne

**Background:** I'm exploring ways to prevent memory leaks in TaskIQ workers and noticed two relevant parameters: 1. `max-async-tasks` (default: 100) - Sets the maximum concurrent tasks per worker 2. `max-tasks-per-child`...

jiangbaihe

How to elegantly use result_backend.set_progress ？？

1

“ @broker.task async def heavy_task(key: str, val: str, context: Context = TaskiqDepends()) -> str: for i in range(10): # Simulate some work await asyncio.sleep(1) # Calculate progress progress = (i...

KitStarLee