Doesn't match scheduler's broker #526

broker = (
    ListQueueBroker(url=settings.REDIS_URL, queue_name='general_queue')
    .with_result_backend(
        RedisAsyncResultBackend(
            redis_url=settings.REDIS_URL,
            keep_results=True,
            result_ex_time=3600,
        )
    )
    .with_middlewares(
        TaskiqAdminMiddleware(
            url=settings.TASKIQ_ADMIN_URL,
            api_token=settings.TASKIQ_ADMIN_API_TOKEN,
            taskiq_broker_name='Fromfolio broker',
        ),
        SmartRetryMiddleware(
            default_retry_count=5,
            default_delay=10,
            use_jitter=True,
            use_delay_exponent=True,
            max_delay_exponent=120,
        ),
    )
)


OTHER_REDIS_URL = settings.REDIS_URL.rsplit('/', 1)[0] + '/1'
other_broker = (
    ListQueueBroker(
        url=OTHER_REDIS_URL,
        queue_name='other_queue',
        max_connection_pool_size=50,
    )
    .with_result_backend(
        RedisAsyncResultBackend(
            redis_url=OTHER_REDIS_URL,
            result_ex_time=3600,
        )
    )
    .with_middlewares(
        TaskiqAdminMiddleware(
            url=settings.TASKIQ_ADMIN_URL,
            api_token=settings.TASKIQ_ADMIN_API_TOKEN,
            taskiq_broker_name='other broker',
        ),
        SmartRetryMiddleware(
            default_retry_count=5,
            default_delay=10,
            use_jitter=True,
            use_delay_exponent=True,
            max_delay_exponent=120,
        ),
        PipelineMiddleware(),
    )
)


redis_source = RedisScheduleSource(settings.REDIS_URL)

scheduler = TaskiqScheduler(
    broker,
    [
        redis_source,
        LabelScheduleSource(broker),
        LabelScheduleSource(other_broker),
    ],
)


task = Pipeline(other_broker, check_user).call_after(
            calc_user_rating,
            apply_id=apply.id,
)