def METHOD_NAME(
    self, request: Request, runner: QueryRunner
) -> QueryExecutionPipeline:
    return MultipleConcurrentPipeline(
        request=request,
        runner=runner,
        query_pipeline_builders=self.__query_pipeline_builders,
        selector_func=self.__selector_func,
        split_rate_limiter=self.__split_rate_limiter,
        ignore_secondary_exceptions=self.__ignore_secondary_exceptions,
        callback_func=self.__callback_func,
    )