Does not work with Redis broker #27

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',
        ),
    )
)

task = Pipeline(in_memory_broker, rate_portfolios).call_after(
            calculate_rate,
            applicant_id=applicant.id,
        )
await task.kiq(selected_portfolios)