taskiq

taskiq copied to clipboard

The docs still mention `AckableMessage.reject`, even though this has been removed in #152. This PR removes it from the docs. Thanks!

srecnig

Add intervals for scheduled task

2

Hi! Following up on PR #399, which I left unfinished half a year ago: In this PR, I want to add intervals for scheduled tasks. List of changes: - Added...

so-saf

danfimov

Slow performance in RedisScheduleSource.get_schedules() leads to missed scheduled jobs

2

I added print statements to measure how long get_schedules() takes and noticed that it sometimes takes over 2 minutes to complete. This causes the "loop that runs every 1 minute"...

AzikDeveloper

Added optional `update_schedule` method for `ScheduleSource`. This method will be simpler to use than delete and then recreate.

danfimov

… when parsing from the command line using the WorkerArgs.from_cli() method. This may be useful if you want to implement a custom command-line interface (CLI) command to run project-specific workers...

dtatarkin

### Description `TimeoutException` is mentioned in [Getting Started > Timeouts](https://taskiq-python.github.io/guide/getting-started.html#timeouts), but it actually doesn't exist. Exceeded task timeout will raise `TimeoutError`, because this is what `asyncio.wait.for()` does. Sorry for disturbing...

DonSlockZ

Currently [Context.requeue](https://github.com/taskiq-python/taskiq/blob/7c92e16d1c420d10888281ab266da2c2b7f4eaec/taskiq/context.py#L20) sends the message directly to the broker and doesn't trigger any middlewares. Is this an intended behaviour? If not, I'd like to make a PR that uses `AsyncKicker`...

ACherryJam

max-prefetch argument doesn't work as expected

1

Thank you for this amazing project. The max-prefetch argument doesn't work as expected. If there are tasks to be consumed, the prefetch queue will be bigger than the argument max-prefetch...

bashirmindee

Hello, I have this configuration. My scheduler tasks are only available on the broker. Other brokers only have my regular tasks. Why am I getting the following warning? > [2025-10-25...

vahidzhe