taskiq

taskiq copied to clipboard

Added on_send_error middleware hook

1

Hi, I am currently working on a retrying feature to ensure the delivery of messages when the queue service is unstable. I found that it could be really helpful to...

hawang-wish

Invert execution orders of post, on_error and shutdown middleware hooks

1

Hi, I've further noticed that we could introduce a slight improvement to make middlewares follow the "onion" execution order. For example, if a `message` is wrapped with `pre_send` of multiple...

hawang-wish

Update watchmedo dependency version

2

`taskiq[reload] (0.11.7) depends on watchdog (>=2.1.9,

mmzeynalli

Add factories

1

dima-dmytruk23

How can I implement launching tasks with an interval of less than one minute, for example 10 seconds? This is necessary in order not to create: ```py while True: await...

kanewi11

Pydantic model arguments with bytes cannot be sent to a worker

2

I have a Pydantic model which has a "bytes" field: ```python class RawData: info: str bytes: bytes ``` And some task definition, for example: ```python @worker.task async def some_task(data: RawData):...

Suoslex

Exception Serialization

4

I've found that if a broker sends a function that raises an exception initialized by **kwargs**, the serialization of that exception will lose those kwargs. This causes the function `exception_to_python()`...

lryan599

Brocker kick exception is not specific

3

I'm currently trying to understand what's going on when i hit an error in an aws lambda. However it only shows "SendTaskError: Cannot send task to the queue" https://github.com/taskiq-python/taskiq/blob/master/taskiq/kicker.py#L163 We...

luis8

Scheduler log spam: broker mismatch between `AsyncSharedBroker` and `Redis ListQueueBroker`

1

While running a Taskiq scheduler that uses taskiq_redis.redis_broker.ListQueueBroker, the worker constantly prints warnings like the following for every scheduled tick: ``` Broker for taskiq_pipelines.shared.filter_tasks doesn't match scheduler's broker Broker for...

Bohdan-Ilchyshyn

how to schedule while using shared_task

1

I got an error: Broker for core.controllers.tasks:best_task_ever `` doesn't match scheduler's broker `` worker.py ``` import sys from src.common.config import BASE_DIR sys.path.append(f"{BASE_DIR}/src") from taskiq import TaskiqScheduler, async_shared_broker from taskiq.schedule_sources import...

tuktamyshev