Pavel Kirilin
Pavel Kirilin
Please do it. Any contribution is valuable, thanks.
I cannot as well on python `3.11.4`. I guess there are multiple version of taskiq or entrypoints.
Add middleware, which will allow to use various functions to determine the delay time before sending
Hi, @Transyltooniaa. Thank you for your interest in this project. You're now assigned.
Add middleware, which will allow to use various functions to determine the delay time before sending
Please fork repo, push changes and make a Pull Request. We will discuss everything within it.
Add middleware, which will allow to use various functions to determine the delay time before sending
Try creating a new middleware module here: https://github.com/taskiq-python/taskiq/tree/develop/taskiq/middlewares
I don't think that this PR is going to be merged in the way it exists now. For two reasons. First of all, where does all processing happens? I guess...
1. There is a difference. Main idea is to replace broker inplace. Before this PR you could write something like this: ```python broker = AioPikaBroker("...") if os.environ.get("APP_ENV", "dev") == "dev":...
Can you please show me which metrics does your application export along with taskiq's metrics?
Because I can run metrics without any issue with custom counter metric. ```python import asyncio from taskiq import PrometheusMiddleware from prometheus_client import Counter from taskiq_redis import ListQueueBroker my_custom_counter = Counter("my_custom_ccc",...
I have another question. Do you use another brokers? Maybe you start multiple brokers and they all try to add same metrics?