Does not work with Redis broker

[mmzeynalli]

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:

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

I get error:

pydantic_core._pydantic_core.PydanticSerializationError: Unable to serialize unknown type: <class 'taskiq_redis.schedule_source.RedisScheduleSource'>