taskiq-pipelines
taskiq-pipelines copied to clipboard
taskiq-python
Task pipelining for taskiq
```python broker = ( ListQueueBroker(url=settings.REDIS_URL) .with_result_backend(RedisAsyncResultBackend(redis_url=settings.REDIS_URL, result_ex_time=3600)) .with_middlewares( TaskiqAdminMiddleware( url=settings.TASKIQ_ADMIN_URL, api_token=settings.TASKIQ_ADMIN_API_TOKEN, taskiq_broker_name='broker', ), ) ) ``` When I use: ```python task = Pipeline(in_memory_broker, rate_portfolios).call_after( calculate_rate, applicant_id=applicant.id, ) await task.kiq(selected_portfolios) ```...
### Description 1. Schedule a pipeline and wait for its result. 2. The first task in the pipeline raises an exception and goes to retry. 3. Retrieve the pipeline result...
### Summary Currently, tasks can be run without using a queue, but pipelines cannot. It would be useful to have the ability to run critical pipeline tasks directly via a...