Pavel Kirilin

So, you can use labeleschedulesource for static crons. It doesn't store anything anywhere. It reads all available tasks and creates schedules based on tasks labels. You can add it along...

I refactored process manager and since then there were no hangs. But I do believe that process manager can be updated, so it will react instantly to the events. One...

Actually it's a mystery for me. Most probably it happens because workers start before singral interceptors are called. Because I only experienced it when I was sending "^C" signal before...

There's no such behavior. At this time. But actually, it would be nice to be able to do so. I wanted to implement it, but couldn't come up with general...

Actually, we might have removed this queue. It's here for historical reasons from old versions. But I agree that we might implement reject to all brokers. Can you please publish...

That might be a good idea. Actually I'd want to implement it the way gunicorn did. Then actually check all files that are actually used by your python project and...

Currently there's no such functionality, but I really do want to define an interface to setup such task interruptors. I'm open for discussion on that.

Yes, it's possible. ```python from taskiq_redis import ListQueueBroker from taskiq.kicker import AsyncKicker broker = ListQueueBroker("redis://localhost:6379") @broker.task(task_name="task_name") def task(): print("Hello World!") async def main(): await broker.startup() await AsyncKicker("task_name", broker, {}).kiq() await...

Sure. I would suggest to use taskiq scheduler for that. Generic implementation only uses labels, but you can add implementation that fits you more. I created an example of a...

Exactly.