candle-einops 0.2.0

use std::cell::RefCell;
use std::collections::VecDeque;

use candle_core::{DType, Device, Result, Tensor};

use crate::backend::execute_tensor_permute_and_compose;

/// Validated compile-time plan for the unary explicit-output einsum slice.
#[doc(hidden)]
#[derive(Clone, Copy, Debug)]
pub struct UnaryEinsumSpec<'a> {
    input_rank: usize,
    output_rank: usize,
    permutation: &'a [usize],
}

impl<'a> UnaryEinsumSpec<'a> {
    /// Constructs a plan emitted by `candle-einops-macros`.
    #[doc(hidden)]
    pub const fn new(input_rank: usize, output_rank: usize, permutation: &'a [usize]) -> Self {
        Self {
            input_rank,
            output_rank,
            permutation,
        }
    }
}

/// Executes a unary explicit-output einsum plan.
#[doc(hidden)]
pub fn execute_unary_einsum<T>(operand: &T, spec: UnaryEinsumSpec<'_>) -> Result<Tensor>
where
    T: AsRef<Tensor> + ?Sized,
{
    let operand = operand.as_ref();
    if operand.rank() != spec.input_rank {
        candle_core::bail!(
            "einsum operand 0 has rank {}, expected {} for the equation input",
            operand.rank(),
            spec.input_rank,
        )
    }
    if spec.output_rank > spec.input_rank {
        candle_core::bail!(
            "invalid unary einsum plan: output rank {} exceeds input rank {}",
            spec.output_rank,
            spec.input_rank,
        )
    }
    if spec.permutation.len() != spec.input_rank {
        candle_core::bail!(
            "invalid unary einsum plan: permutation has {} axes, expected {}",
            spec.permutation.len(),
            spec.input_rank,
        )
    }

    let mut seen = vec![false; spec.input_rank];
    for &axis in spec.permutation {
        if axis >= spec.input_rank {
            candle_core::bail!(
                "invalid unary einsum plan: permutation axis {axis} is out of range for rank {}",
                spec.input_rank,
            )
        }
        if seen[axis] {
            candle_core::bail!(
                "invalid unary einsum plan: permutation contains axis {axis} more than once"
            )
        }
        seen[axis] = true;
    }

    let is_identity = spec.permutation.iter().copied().eq(0..spec.input_rank);
    let mut output = if is_identity {
        operand.clone()
    } else {
        operand
            .permute(spec.permutation)
            .map_err(|error| error.context("einsum unary permutation"))?
    };

    if spec.output_rank < spec.input_rank {
        let reduction_axes = (spec.output_rank..spec.input_rank).collect::<Vec<_>>();
        output = output
            .sum(reduction_axes.as_slice())
            .map_err(|error| error.context("einsum unary reduction"))?;
    }

    Ok(output)
}

/// Validated compile-time plan for a binary explicit-output einsum.
#[doc(hidden)]
#[derive(Clone, Copy, Debug)]
pub struct BinaryEinsumSpec<'a> {
    input_ranks: [usize; 2],
    reduction_axes: [&'a [usize]; 2],
    permutations: [&'a [usize]; 2],
    batch_rank: usize,
    left_free_rank: usize,
    contracted_rank: usize,
    right_free_rank: usize,
    batch_labels: &'a [&'a str],
    contracted_labels: &'a [&'a str],
    output_permutation: &'a [usize],
}

/// One compile-time axis-list pattern containing at most one runtime ellipsis.
#[doc(hidden)]
#[derive(Clone, Copy, Debug)]
pub struct EinsumAxisPattern<'a> {
    labels: &'a [&'a str],
    ellipsis_position: Option<usize>,
}

impl<'a> EinsumAxisPattern<'a> {
    /// Constructs an axis pattern emitted by `candle-einops-macros`.
    #[doc(hidden)]
    pub const fn new(labels: &'a [&'a str], ellipsis_position: Option<usize>) -> Self {
        Self {
            labels,
            ellipsis_position,
        }
    }
}

/// Runtime-normalized plan for an equation containing ellipses, repeated
/// labels, or more than two operands.
#[doc(hidden)]
#[derive(Clone, Copy, Debug)]
pub struct EllipsisEinsumSpec<'a> {
    operands: &'a [EinsumAxisPattern<'a>],
    output: EinsumAxisPattern<'a>,
}

impl<'a> EllipsisEinsumSpec<'a> {
    /// Constructs an ellipsis plan emitted by `candle-einops-macros`.
    #[doc(hidden)]
    pub const fn new(operands: &'a [EinsumAxisPattern<'a>], output: EinsumAxisPattern<'a>) -> Self {
        Self { operands, output }
    }
}

impl<'a> BinaryEinsumSpec<'a> {
    /// Constructs a plan emitted by `candle-einops-macros`.
    #[doc(hidden)]
    #[allow(clippy::too_many_arguments)]
    pub const fn new(
        input_ranks: [usize; 2],
        reduction_axes: [&'a [usize]; 2],
        permutations: [&'a [usize]; 2],
        batch_rank: usize,
        left_free_rank: usize,
        contracted_rank: usize,
        right_free_rank: usize,
        batch_labels: &'a [&'a str],
        contracted_labels: &'a [&'a str],
        output_permutation: &'a [usize],
    ) -> Self {
        Self {
            input_ranks,
            reduction_axes,
            permutations,
            batch_rank,
            left_free_rank,
            contracted_rank,
            right_free_rank,
            batch_labels,
            contracted_labels,
            output_permutation,
        }
    }
}

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
enum BinaryExecution {
    Multiply,
    CanonicalMatmul,
    General,
}

/// Executes a binary GEMM-lowered explicit-output einsum plan.
#[doc(hidden)]
pub fn execute_binary_einsum<L, R>(
    left: &L,
    right: &R,
    spec: BinaryEinsumSpec<'_>,
) -> Result<Tensor>
where
    L: AsRef<Tensor> + ?Sized,
    R: AsRef<Tensor> + ?Sized,
{
    execute_binary_with(left, right, spec, BinaryExecution::General)
}

/// Executes a binary equation with no contracted labels as broadcast multiplication.
#[doc(hidden)]
pub fn execute_binary_multiply<L, R>(
    left: &L,
    right: &R,
    spec: BinaryEinsumSpec<'_>,
) -> Result<Tensor>
where
    L: AsRef<Tensor> + ?Sized,
    R: AsRef<Tensor> + ?Sized,
{
    execute_binary_with(left, right, spec, BinaryExecution::Multiply)
}

/// Executes a canonical rank-two or rank-three contraction with direct matmul.
#[doc(hidden)]
pub fn execute_canonical_binary_einsum<L, R>(
    left: &L,
    right: &R,
    spec: BinaryEinsumSpec<'_>,
) -> Result<Tensor>
where
    L: AsRef<Tensor> + ?Sized,
    R: AsRef<Tensor> + ?Sized,
{
    execute_binary_with(left, right, spec, BinaryExecution::CanonicalMatmul)
}

fn execute_binary_with<L, R>(
    left: &L,
    right: &R,
    spec: BinaryEinsumSpec<'_>,
    requested_execution: BinaryExecution,
) -> Result<Tensor>
where
    L: AsRef<Tensor> + ?Sized,
    R: AsRef<Tensor> + ?Sized,
{
    let left = left.as_ref();
    let right = right.as_ref();
    for (index, (operand, expected_rank)) in
        [left, right].into_iter().zip(spec.input_ranks).enumerate()
    {
        if operand.rank() != expected_rank {
            candle_core::bail!(
                "einsum operand {index} has rank {}, expected {expected_rank} for the equation input",
                operand.rank(),
            )
        }
    }
    if left.dtype() != right.dtype() {
        candle_core::bail!(
            "einsum operands have different dtypes: left {:?}, right {:?}",
            left.dtype(),
            right.dtype(),
        )
    }
    if !left.device().same_device(right.device()) {
        candle_core::bail!(
            "einsum operands are on different devices: left {:?}, right {:?}",
            left.device(),
            right.device(),
        )
    }

    let left = prepare_operand(
        left,
        0,
        spec.input_ranks[0],
        spec.reduction_axes[0],
        spec.permutations[0],
    )?;
    let right = prepare_operand(
        right,
        1,
        spec.input_ranks[1],
        spec.reduction_axes[1],
        spec.permutations[1],
    )?;

    let left_expected_rank = spec
        .batch_rank
        .checked_add(spec.left_free_rank)
        .and_then(|rank| rank.checked_add(spec.contracted_rank))
        .ok_or_else(|| {
            candle_core::Error::msg("einsum binary canonical left rank overflows usize")
        })?;
    let right_expected_rank = spec
        .batch_rank
        .checked_add(spec.contracted_rank)
        .and_then(|rank| rank.checked_add(spec.right_free_rank))
        .ok_or_else(|| {
            candle_core::Error::msg("einsum binary canonical right rank overflows usize")
        })?;
    if left.rank() != left_expected_rank || right.rank() != right_expected_rank {
        candle_core::bail!(
            "invalid binary einsum plan: canonical ranks are left {}, right {}, expected left {left_expected_rank}, right {right_expected_rank}",
            left.rank(),
            right.rank(),
        )
    }
    if spec.batch_labels.len() != spec.batch_rank
        || spec.contracted_labels.len() != spec.contracted_rank
    {
        candle_core::bail!(
            "invalid binary einsum plan: shared-label metadata does not match canonical ranks"
        )
    }

    let left_dims = left.dims().to_vec();
    let right_dims = right.dims().to_vec();
    let mut batch_dims = Vec::with_capacity(spec.batch_rank);
    for axis in 0..spec.batch_rank {
        batch_dims.push(resolve_extent(
            spec.batch_labels[axis],
            left_dims[axis],
            right_dims[axis],
        )?);
    }
    let left_free_start = spec.batch_rank;
    let contracted_left_start = left_free_start + spec.left_free_rank;
    let contracted_right_start = spec.batch_rank;
    let mut contracted_dims = Vec::with_capacity(spec.contracted_rank);
    for axis in 0..spec.contracted_rank {
        contracted_dims.push(resolve_extent(
            spec.contracted_labels[axis],
            left_dims[contracted_left_start + axis],
            right_dims[contracted_right_start + axis],
        )?);
    }
    let left_free_dims = &left_dims[left_free_start..contracted_left_start];
    let right_free_start = contracted_right_start + spec.contracted_rank;
    let right_free_dims = &right_dims[right_free_start..];

    let mut left_shape = batch_dims.clone();
    left_shape.extend_from_slice(left_free_dims);
    left_shape.extend_from_slice(&contracted_dims);
    let mut right_shape = batch_dims.clone();
    right_shape.extend_from_slice(&contracted_dims);
    right_shape.extend_from_slice(right_free_dims);

    let b = checked_product(&batch_dims, "batch (B)")?;
    let m = checked_product(left_free_dims, "left-free (M)")?;
    let k = checked_product(&contracted_dims, "contracted (K)")?;
    let n = checked_product(right_free_dims, "right-free (N)")?;

    let mut canonical_output_shape = batch_dims.clone();
    canonical_output_shape.extend_from_slice(left_free_dims);
    canonical_output_shape.extend_from_slice(right_free_dims);
    validate_permutation(
        spec.output_permutation,
        canonical_output_shape.len(),
        "output",
    )?;

    let execution = if spec.contracted_rank == 0 {
        BinaryExecution::Multiply
    } else {
        requested_execution
    };

    if execution == BinaryExecution::CanonicalMatmul {
        let canonical = spec.left_free_rank == 1
            && spec.contracted_rank == 1
            && spec.right_free_rank == 1
            && spec.reduction_axes.iter().all(|axes| axes.is_empty())
            && spec
                .permutations
                .iter()
                .all(|permutation| permutation.iter().copied().eq(0..permutation.len()));
        if !canonical {
            candle_core::bail!("invalid binary einsum plan: direct matmul path is not canonical")
        }
    }

    if execution != BinaryExecution::Multiply && (b == 0 || m == 0 || k == 0 || n == 0) {
        let output = graph_preserving_zero(&left, &right, &canonical_output_shape)?;
        return apply_output_permutation(output, spec.output_permutation);
    }

    if execution == BinaryExecution::Multiply {
        if spec.contracted_rank != 0 {
            candle_core::bail!(
                "invalid binary einsum plan: multiply fast path received contracted axes"
            )
        }
        let mut left = left;
        for _ in 0..spec.right_free_rank {
            left = left.unsqueeze(left.rank()).map_err(|error| {
                error.context("einsum binary multiply left free-axis alignment")
            })?;
        }
        let mut right = right;
        for _ in 0..spec.left_free_rank {
            right = right.unsqueeze(spec.batch_rank).map_err(|error| {
                error.context("einsum binary multiply right free-axis alignment")
            })?;
        }
        let output = left
            .broadcast_mul(&right)
            .map_err(|error| error.context("einsum binary broadcast multiplication"))?;
        return apply_output_permutation(output, spec.output_permutation);
    }

    if execution == BinaryExecution::CanonicalMatmul {
        let left =
            materialize_broadcast_if_needed(&left, &left_shape, "einsum binary left broadcast")?;
        let right =
            materialize_broadcast_if_needed(&right, &right_shape, "einsum binary right broadcast")?;
        let output = left
            .matmul(&right)
            .map_err(|error| error.context("einsum binary B/M/K/N matmul"))?;
        return apply_output_permutation(output, spec.output_permutation);
    }

    let left = left
        .broadcast_as(left_shape)
        .map_err(|error| error.context("einsum binary left broadcast"))?;
    let left = pack_canonical_operand(
        &left,
        &[b, m, k],
        &[spec.batch_rank, spec.left_free_rank, spec.contracted_rank],
        "einsum binary left B/M/K reshape",
    )?;
    let right = right
        .broadcast_as(right_shape)
        .map_err(|error| error.context("einsum binary right broadcast"))?;
    let right = pack_canonical_operand(
        &right,
        &[b, k, n],
        &[spec.batch_rank, spec.contracted_rank, spec.right_free_rank],
        "einsum binary right B/K/N reshape",
    )?;
    let output = left
        .matmul(&right)
        .map_err(|error| error.context("einsum binary B/M/K/N matmul"))?;
    let output = output
        .reshape(canonical_output_shape)
        .map_err(|error| error.context("einsum binary canonical output reshape"))?;
    apply_output_permutation(output, spec.output_permutation)
}

fn graph_preserving_zero(left: &Tensor, right: &Tensor, shape: &[usize]) -> Result<Tensor> {
    let left = left
        .flatten_all()
        .map_err(|error| error.context("einsum binary left zero flatten"))?;
    let right = right
        .flatten_all()
        .map_err(|error| error.context("einsum binary right zero flatten"))?;
    Tensor::cat(&[&left, &right], 0)
        .and_then(|operands| operands.sum_all())
        .map_err(|error| error.context("einsum binary zero operand anchor"))?
        .broadcast_as(shape)
        .map_err(|error| error.context("einsum binary zero output broadcast"))
}

/// Expands and executes a unary equation containing an ellipsis.
#[doc(hidden)]
pub fn execute_unary_ellipsis_einsum<T>(operand: &T, spec: EllipsisEinsumSpec<'_>) -> Result<Tensor>
where
    T: AsRef<Tensor> + ?Sized,
{
    if spec.operands.len() != 1 {
        candle_core::bail!(
            "invalid ellipsis einsum plan: unary execution received {} operand patterns",
            spec.operands.len()
        )
    }
    let operand = operand.as_ref();
    let capture = ellipsis_capture(operand, 0, spec.operands[0])?;
    let normalized = normalize_ellipsis_operand(operand, spec.operands[0], capture, capture, 0)?;
    let input_axes = expand_axis_pattern(spec.operands[0], capture, true);
    let (normalized, input_axes) = normalize_repeated_axes(normalized, input_axes, 0)?;
    let output_axes = expand_axis_pattern(spec.output, capture, false);
    validate_expanded_output(&[&input_axes], &output_axes)?;
    let permutation = output_axes
        .iter()
        .chain(input_axes.iter().filter(|axis| !output_axes.contains(axis)))
        .map(|axis| {
            input_axes
                .iter()
                .position(|candidate| candidate == axis)
                .expect("validated unary ellipsis axis")
        })
        .collect::<Vec<_>>();
    execute_unary_einsum(
        &normalized,
        UnaryEinsumSpec::new(input_axes.len(), output_axes.len(), &permutation),
    )
}

/// Expands and executes a binary equation containing an ellipsis.
#[doc(hidden)]
pub fn execute_binary_ellipsis_einsum<L, R>(
    left: &L,
    right: &R,
    spec: EllipsisEinsumSpec<'_>,
) -> Result<Tensor>
where
    L: AsRef<Tensor> + ?Sized,
    R: AsRef<Tensor> + ?Sized,
{
    if spec.operands.len() != 2 {
        candle_core::bail!(
            "invalid ellipsis einsum plan: binary execution received {} operand patterns",
            spec.operands.len()
        )
    }
    let left = left.as_ref();
    let right = right.as_ref();
    let captures = [
        ellipsis_capture(left, 0, spec.operands[0])?,
        ellipsis_capture(right, 1, spec.operands[1])?,
    ];
    let maximum_capture = captures[0].max(captures[1]);
    let left = normalize_ellipsis_operand(left, spec.operands[0], captures[0], maximum_capture, 0)?;
    let right =
        normalize_ellipsis_operand(right, spec.operands[1], captures[1], maximum_capture, 1)?;
    let left_axes = expand_axis_pattern(spec.operands[0], maximum_capture, true);
    let right_axes = expand_axis_pattern(spec.operands[1], maximum_capture, true);
    let (left, left_axes) = normalize_repeated_axes(left, left_axes, 0)?;
    let (right, right_axes) = normalize_repeated_axes(right, right_axes, 1)?;
    let output_axes = expand_axis_pattern(spec.output, maximum_capture, false);
    validate_expanded_output(&[&left_axes, &right_axes], &output_axes)?;
    execute_expanded_binary(&left, &right, &left_axes, &right_axes, &output_axes)
}

/// Converts one generated operand binding to the tensor reference used by the
/// arbitrary-arity runtime ABI.
#[doc(hidden)]
pub fn einsum_operand_ref<T>(operand: &T) -> &Tensor
where
    T: AsRef<Tensor> + ?Sized,
{
    operand.as_ref()
}

/// Normalizes and greedily contracts an arbitrary number of operands.
#[doc(hidden)]
pub fn execute_nary_einsum(operands: &[&Tensor], spec: EllipsisEinsumSpec<'_>) -> Result<Tensor> {
    execute_nary_einsum_internal(operands, spec, NaryExecutionStrategy::Selected)
        .map(|(tensor, _)| tensor)
}

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
enum NaryExecutionStrategy {
    Selected,
    #[cfg(test)]
    StreamingGreedy,
}

#[derive(Clone, Debug, Default, Eq, PartialEq)]
struct NaryExecutionTrace {
    used_exact: bool,
    used_cached_greedy: bool,
    member_sequence: Vec<(u64, u64)>,
    final_permutations: usize,
    intermediates: Vec<NaryIntermediateTrace>,
}

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryIntermediateTrace {
    canonical: bool,
    estimated: NaryPairCost,
    execution_graph: NaryPairCost,
    output_layout: NaryLayoutEstimate,
}

fn prepare_nary_einsum<'a>(
    operands: &[&Tensor],
    spec: EllipsisEinsumSpec<'a>,
) -> Result<(Vec<PlannedOperand<'a>>, Vec<ExpandedAxis<'a>>)> {
    if operands.is_empty() {
        candle_core::bail!("invalid n-ary einsum plan: at least one operand is required")
    }
    if spec.operands.len() != operands.len() {
        candle_core::bail!(
            "invalid n-ary einsum plan: received {} tensors but {} operand patterns",
            operands.len(),
            spec.operands.len()
        )
    }
    let first = operands[0];
    for (index, operand) in operands.iter().copied().enumerate().skip(1) {
        if operand.dtype() != first.dtype() {
            candle_core::bail!(
                "einsum operands have different dtypes: operand 0 {:?}, operand {index} {:?}",
                first.dtype(),
                operand.dtype()
            )
        }
        if !operand.device().same_device(first.device()) {
            candle_core::bail!(
                "einsum operands are on different devices: operand 0 {:?}, operand {index} {:?}",
                first.device(),
                operand.device()
            )
        }
    }
    let captures = operands
        .iter()
        .zip(spec.operands)
        .enumerate()
        .map(|(index, (operand, pattern))| ellipsis_capture(operand, index, *pattern))
        .collect::<Result<Vec<_>>>()?;
    let maximum_capture = captures.iter().copied().max().unwrap_or(0);
    let mut planned = Vec::with_capacity(operands.len());
    for (index, ((operand, pattern), capture)) in
        operands.iter().zip(spec.operands).zip(captures).enumerate()
    {
        let normalized =
            normalize_ellipsis_operand(operand, *pattern, capture, maximum_capture, index)?;
        let axes = expand_axis_pattern(*pattern, maximum_capture, true);
        let (tensor, axes) = normalize_repeated_axes(normalized, axes, index)?;
        planned.push(PlannedOperand {
            tensor,
            axes,
            stable_ordinal: index,
            members: 1_u64.checked_shl(index as u32).unwrap_or(0),
        });
    }
    let output_axes = expand_axis_pattern(spec.output, maximum_capture, false);
    let input_axes = planned
        .iter()
        .map(|operand| operand.axes.as_slice())
        .collect::<Vec<_>>();
    validate_expanded_output(&input_axes, &output_axes)?;
    validate_nary_broadcasts(&planned)?;
    Ok((planned, output_axes))
}

fn select_prepared_nary_plan<'a>(
    planned: &[PlannedOperand<'a>],
    output_axes: &[ExpandedAxis<'a>],
) -> NaryPlannerDecision<'a> {
    let first = &planned[0].tensor;
    let metadata = prepared_nary_metadata(planned);
    select_layout_aware_plan(
        &metadata,
        output_axes,
        first.dtype(),
        first.device().is_cpu(),
    )
}

fn prepared_nary_metadata<'a>(planned: &[PlannedOperand<'a>]) -> Vec<NaryPlannerMetadata<'a>> {
    planned
        .iter()
        .map(|operand| NaryPlannerMetadata {
            stable_ordinal: operand.stable_ordinal,
            axes: operand
                .axes
                .iter()
                .copied()
                .zip(operand.tensor.dims().iter().copied())
                .collect(),
            layout: if operand.tensor.is_contiguous() {
                NaryLayoutEstimate::Contiguous
            } else {
                NaryLayoutEstimate::Strided(operand.tensor.stride().to_vec())
            },
            members: operand.members,
        })
        .collect()
}

/// Runs production n-ary preparation and selection without executing a plan.
#[cfg(feature = "benchmark-internals")]
#[doc(hidden)]
pub fn benchmark_nary_planner_selects_exact(
    operands: &[&Tensor],
    spec: EllipsisEinsumSpec<'_>,
) -> Result<bool> {
    let (planned, output_axes) = prepare_nary_einsum(operands, spec)?;
    Ok(matches!(
        select_prepared_nary_plan(&planned, &output_axes),
        NaryPlannerDecision::Exact(_)
    ))
}

/// Public-operation estimates from the production binary lowering classifier.
#[cfg(feature = "benchmark-internals")]
#[doc(hidden)]
#[derive(Clone, Debug, Eq, PartialEq)]
pub struct BenchmarkBinaryGraphEstimate {
    pub work: u128,
    pub output_elements: u128,
    pub copy_bytes: u128,
    pub submissions: u128,
}

/// Runs the production lowering classifier without executing tensor operations.
#[cfg(feature = "benchmark-internals")]
#[doc(hidden)]
pub fn benchmark_binary_graph_estimate(
    left_labels: &[&str],
    left_dims: &[usize],
    left_strides: &[usize],
    right_labels: &[&str],
    right_dims: &[usize],
    right_strides: &[usize],
    output_labels: &[&str],
) -> Result<BenchmarkBinaryGraphEstimate> {
    let left_axes = left_labels
        .iter()
        .copied()
        .map(ExpandedAxis::Named)
        .collect::<Vec<_>>();
    let right_axes = right_labels
        .iter()
        .copied()
        .map(ExpandedAxis::Named)
        .collect::<Vec<_>>();
    let output_axes = output_labels
        .iter()
        .copied()
        .map(ExpandedAxis::Named)
        .collect::<Vec<_>>();
    let graph = classify_expanded_binary_graph(
        BinaryGraphOperand {
            axes: &left_axes,
            dims: left_dims,
            layout: BinaryOperandLayout::Strided(left_strides),
        },
        BinaryGraphOperand {
            axes: &right_axes,
            dims: right_dims,
            layout: BinaryOperandLayout::Strided(right_strides),
        },
        &output_axes,
        4,
    )?;
    Ok(BenchmarkBinaryGraphEstimate {
        work: graph.work,
        output_elements: graph.output_elements,
        copy_bytes: graph.copy_bytes,
        submissions: graph.submissions,
    })
}

fn execute_nary_einsum_internal<'a>(
    operands: &[&Tensor],
    spec: EllipsisEinsumSpec<'a>,
    strategy: NaryExecutionStrategy,
) -> Result<(Tensor, NaryExecutionTrace)> {
    let (mut planned, output_axes) = prepare_nary_einsum(operands, spec)?;
    let global_axis_order = stable_axis_order(&planned);

    let decision = if strategy == NaryExecutionStrategy::Selected {
        select_prepared_nary_plan(&planned, &output_axes)
    } else {
        NaryPlannerDecision::Greedy(NaryGreedyReason::Arity)
    };
    let calibrated_greedy = matches!(
        &decision,
        NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration)
    );
    let greedy_cache_key = calibrated_greedy
        .then(|| nary_plan_cache_key(&prepared_nary_metadata(&planned), &output_axes));
    let cached_greedy = greedy_cache_key.as_ref().and_then(cached_nary_sequence);
    let mut trace = NaryExecutionTrace::default();
    match decision {
        NaryPlannerDecision::Exact(plan) => {
            trace.used_exact = true;
            for step in plan.steps {
                let left_index = planned
                    .iter()
                    .position(|operand| operand.members == step.members.0)
                    .expect("exact plan left member set remains live");
                let right_index = planned
                    .iter()
                    .position(|operand| operand.members == step.members.1)
                    .expect("exact plan right member set remains live");
                debug_assert!(left_index < right_index);
                let right = planned.remove(right_index);
                let left = planned.remove(left_index);
                let graph = classify_expanded_binary_graph(
                    BinaryGraphOperand {
                        axes: &left.axes,
                        dims: left.tensor.dims(),
                        layout: BinaryOperandLayout::Strided(left.tensor.stride()),
                    },
                    BinaryGraphOperand {
                        axes: &right.axes,
                        dims: right.tensor.dims(),
                        layout: BinaryOperandLayout::Strided(right.tensor.stride()),
                    },
                    &step.output_axes,
                    left.tensor.dtype().size_in_bytes(),
                )?;
                let execution_graph = graph.cost();
                debug_assert_eq!(step.estimate, execution_graph);
                let (tensor, axes) = execute_expanded_binary_canonical(
                    &left.tensor,
                    &right.tensor,
                    &left.axes,
                    &right.axes,
                    &step.output_axes,
                )?;
                debug_assert_eq!(axes, step.output_axes);
                planned.insert(
                    left_index,
                    PlannedOperand {
                        tensor,
                        axes,
                        stable_ordinal: left.stable_ordinal.min(right.stable_ordinal),
                        members: left.members | right.members,
                    },
                );
                trace.member_sequence.push(step.members);
                trace.intermediates.push(NaryIntermediateTrace {
                    canonical: true,
                    estimated: step.estimate,
                    execution_graph,
                    output_layout: graph.output_layout,
                });
            }
        }
        NaryPlannerDecision::Greedy(_) => {
            trace.used_cached_greedy = cached_greedy.is_some();
            let mut cached_steps = cached_greedy.as_deref().unwrap_or_default().iter();
            while planned.len() > 1 {
                let selected = if let Some(&(left_members, right_members)) = cached_steps.next() {
                    let left = planned
                        .iter()
                        .position(|operand| operand.members == left_members)
                        .ok_or_else(|| {
                            candle_core::Error::msg("cached greedy left members are not live")
                        })?;
                    let right = planned
                        .iter()
                        .position(|operand| operand.members == right_members)
                        .ok_or_else(|| {
                            candle_core::Error::msg("cached greedy right members are not live")
                        })?;
                    estimate_pair_with_order(
                        &planned,
                        left,
                        right,
                        &output_axes,
                        &global_axis_order,
                    )?
                } else {
                    select_nary_pair_with_order(&planned, &output_axes, &global_axis_order)?
                };
                let right = planned.remove(selected.right);
                let left = planned.remove(selected.left);
                let tensor = execute_expanded_binary(
                    &left.tensor,
                    &right.tensor,
                    &left.axes,
                    &right.axes,
                    &selected.output_axes,
                )?;
                trace.member_sequence.push((left.members, right.members));
                planned.insert(
                    selected.left,
                    PlannedOperand {
                        tensor,
                        axes: selected.output_axes,
                        stable_ordinal: left.stable_ordinal.min(right.stable_ordinal),
                        members: left.members | right.members,
                    },
                );
            }
            if let Some(key) = greedy_cache_key
                && !trace.used_cached_greedy
            {
                cache_nary_sequence(key, trace.member_sequence.clone());
            }
        }
    }

    let final_operand = planned
        .pop()
        .expect("non-empty n-ary plan retains one operand");
    let permutation = output_axes
        .iter()
        .chain(
            final_operand
                .axes
                .iter()
                .filter(|axis| !output_axes.contains(axis)),
        )
        .map(|axis| {
            final_operand
                .axes
                .iter()
                .position(|candidate| candidate == axis)
                .expect("validated final n-ary output axis")
        })
        .collect::<Vec<_>>();
    let tensor = execute_unary_einsum(
        &final_operand.tensor,
        UnaryEinsumSpec::new(final_operand.axes.len(), output_axes.len(), &permutation),
    )?;
    trace.final_permutations = 1;
    Ok((tensor, trace))
}

#[cfg(test)]
fn execute_nary_einsum_for_test<'a>(
    operands: &[&Tensor],
    spec: EllipsisEinsumSpec<'a>,
    strategy: NaryExecutionStrategy,
) -> Result<(Tensor, NaryExecutionTrace)> {
    execute_nary_einsum_internal(operands, spec, strategy)
}

fn execute_expanded_binary(
    left: &Tensor,
    right: &Tensor,
    left_axes: &[ExpandedAxis<'_>],
    right_axes: &[ExpandedAxis<'_>],
    output_axes: &[ExpandedAxis<'_>],
) -> Result<Tensor> {
    let graph = classify_expanded_binary_graph(
        BinaryGraphOperand {
            axes: left_axes,
            dims: left.dims(),
            layout: BinaryOperandLayout::Strided(left.stride()),
        },
        BinaryGraphOperand {
            axes: right_axes,
            dims: right.dims(),
            layout: BinaryOperandLayout::Strided(right.stride()),
        },
        output_axes,
        left.dtype().size_in_bytes(),
    )?;
    let plan = graph.plan;
    let batch_label_storage = plan
        .batch
        .iter()
        .map(ExpandedAxis::display_name)
        .collect::<Vec<_>>();
    let contracted_label_storage = plan
        .contracted
        .iter()
        .map(ExpandedAxis::display_name)
        .collect::<Vec<_>>();
    let batch_labels = batch_label_storage
        .iter()
        .map(String::as_str)
        .collect::<Vec<_>>();
    let contracted_labels = contracted_label_storage
        .iter()
        .map(String::as_str)
        .collect::<Vec<_>>();
    execute_binary_einsum(
        left,
        right,
        BinaryEinsumSpec::new(
            [left_axes.len(), right_axes.len()],
            [&plan.left_reductions, &plan.right_reductions],
            [&plan.left_permutation, &plan.right_permutation],
            plan.batch.len(),
            plan.left_free.len(),
            plan.contracted.len(),
            plan.right_free.len(),
            &batch_labels,
            &contracted_labels,
            &plan.output_permutation,
        ),
    )
}

fn execute_expanded_binary_canonical<'a>(
    left: &Tensor,
    right: &Tensor,
    left_axes: &[ExpandedAxis<'a>],
    right_axes: &[ExpandedAxis<'a>],
    retained_axes: &[ExpandedAxis<'a>],
) -> Result<(Tensor, Vec<ExpandedAxis<'a>>)> {
    let plan = classify_expanded_binary(left_axes, right_axes, retained_axes);
    let canonical = plan
        .batch
        .iter()
        .chain(&plan.left_free)
        .chain(&plan.right_free)
        .copied()
        .collect::<Vec<_>>();
    let tensor = execute_expanded_binary(left, right, left_axes, right_axes, &canonical)?;
    Ok((tensor, canonical))
}

struct PlannedOperand<'a> {
    tensor: Tensor,
    axes: Vec<ExpandedAxis<'a>>,
    stable_ordinal: usize,
    members: u64,
}

impl<'a> PlannedOperand<'a> {
    #[cfg(test)]
    fn new_for_test(
        shape: (usize, usize),
        labels: &[&'a str],
        stable_ordinal: usize,
    ) -> Result<Self> {
        Ok(Self {
            tensor: Tensor::zeros(shape, candle_core::DType::F32, &candle_core::Device::Cpu)?,
            axes: labels.iter().copied().map(ExpandedAxis::Named).collect(),
            stable_ordinal,
            members: 1_u64 << stable_ordinal,
        })
    }
}

#[derive(Clone, Debug, Eq, PartialEq)]
enum NaryLayoutEstimate {
    Contiguous,
    Strided(Vec<usize>),
    Unsupported,
}

impl NaryLayoutEstimate {
    fn as_binary(&self) -> BinaryOperandLayout<'_> {
        match self {
            Self::Contiguous => BinaryOperandLayout::Contiguous,
            Self::Strided(strides) => BinaryOperandLayout::Strided(strides),
            Self::Unsupported => BinaryOperandLayout::Unsupported,
        }
    }
}

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryPlannerMetadata<'a> {
    stable_ordinal: usize,
    axes: Vec<(ExpandedAxis<'a>, usize)>,
    layout: NaryLayoutEstimate,
    members: u64,
}

impl<'a> NaryPlannerMetadata<'a> {
    #[cfg(test)]
    fn new_for_test(
        stable_ordinal: usize,
        axes: &[(&'a str, usize)],
        layout: NaryLayoutEstimate,
    ) -> Self {
        Self {
            stable_ordinal,
            axes: axes
                .iter()
                .map(|&(axis, extent)| (ExpandedAxis::Named(axis), extent))
                .collect(),
            layout,
            members: 1_u64.checked_shl(stable_ordinal as u32).unwrap_or(0),
        }
    }

    fn elements(&self) -> Result<u128> {
        checked_nary_product(
            &self
                .axes
                .iter()
                .map(|(_, extent)| *extent)
                .collect::<Vec<_>>(),
        )
    }
}

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryPairCost {
    flops: u128,
    output_elements: u128,
    copy_bytes: u128,
    submissions: u128,
}

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryPlanStep<'a> {
    members: (u64, u64),
    output_axes: Vec<ExpandedAxis<'a>>,
    estimate: NaryPairCost,
}

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryPlanMetrics {
    flops: u128,
    intermediate_elements: u128,
    output_elements: u128,
    copy_bytes: u128,
    peak_live_elements: u128,
    submissions: u128,
    score: u128,
}

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryContractionPlan<'a> {
    steps: Vec<NaryPlanStep<'a>>,
    metrics: NaryPlanMetrics,
}

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
enum NaryGreedyReason {
    Arity,
    DType,
    Backend,
    UnsupportedLayout,
    BelowFlopThreshold,
    Calibration,
    ModelFailure,
}

// The bounded exact model remains available for analysis, but the frozen CPU
// matrix has not demonstrated an end-to-end execution win over streaming
// greedy. Re-enable only with repeated-process evidence, not model score alone.
const EXACT_NARY_EXECUTION_CALIBRATED: bool = false;

#[derive(Clone, Debug, Eq, PartialEq)]
enum NaryPlannerDecision<'a> {
    Greedy(NaryGreedyReason),
    Exact(NaryContractionPlan<'a>),
}

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryPlanCacheOperand {
    axes: Vec<String>,
    dims: Vec<usize>,
    layout: u8,
    strides: Vec<usize>,
}

type NaryMemberPair = (u64, u64);

#[derive(Clone, Debug, Eq, PartialEq)]
struct NaryPlanCacheKey {
    operands: Vec<NaryPlanCacheOperand>,
    output: Vec<String>,
}

struct NaryCachedPlan {
    key: NaryPlanCacheKey,
    sequence: Vec<NaryMemberPair>,
}

thread_local! {
    static NARY_PLAN_CACHE: RefCell<VecDeque<NaryCachedPlan>> =
        const { RefCell::new(VecDeque::new()) };
}

fn nary_plan_cache_key(
    operands: &[NaryPlannerMetadata<'_>],
    output: &[ExpandedAxis<'_>],
) -> NaryPlanCacheKey {
    NaryPlanCacheKey {
        operands: operands
            .iter()
            .map(|operand| {
                let (layout, strides) = match &operand.layout {
                    NaryLayoutEstimate::Contiguous => (0, Vec::new()),
                    NaryLayoutEstimate::Strided(strides) => (1, strides.clone()),
                    NaryLayoutEstimate::Unsupported => (2, Vec::new()),
                };
                NaryPlanCacheOperand {
                    axes: operand
                        .axes
                        .iter()
                        .map(|(axis, _)| axis.display_name())
                        .collect(),
                    dims: operand.axes.iter().map(|(_, extent)| *extent).collect(),
                    layout,
                    strides,
                }
            })
            .collect(),
        output: output.iter().map(ExpandedAxis::display_name).collect(),
    }
}

fn cached_nary_sequence(key: &NaryPlanCacheKey) -> Option<Vec<NaryMemberPair>> {
    NARY_PLAN_CACHE.with(|cache| {
        cache
            .borrow()
            .iter()
            .find(|candidate| candidate.key == *key)
            .map(|candidate| candidate.sequence.clone())
    })
}

fn cache_nary_sequence(key: NaryPlanCacheKey, sequence: Vec<NaryMemberPair>) {
    NARY_PLAN_CACHE.with(|cache| {
        let mut cache = cache.borrow_mut();
        if cache.iter().any(|candidate| candidate.key == key) {
            return;
        }
        if cache.len() == 16 {
            cache.pop_front();
        }
        cache.push_back(NaryCachedPlan { key, sequence });
    });
}

#[cfg(test)]
fn clear_nary_plan_cache_for_test() {
    NARY_PLAN_CACHE.with(|cache| cache.borrow_mut().clear());
}

fn model_axis_extent(operand: &NaryPlannerMetadata<'_>, axis: ExpandedAxis<'_>) -> Option<usize> {
    operand
        .axes
        .iter()
        .find(|(candidate, _)| *candidate == axis)
        .map(|(_, extent)| *extent)
}

fn model_pair_details<'a>(
    state: &[NaryPlannerMetadata<'a>],
    left: usize,
    right: usize,
    final_output: &[ExpandedAxis<'a>],
    global_axis_order: &[ExpandedAxis<'a>],
) -> Result<(NaryPairCost, NaryPlannerMetadata<'a>)> {
    let left_operand = &state[left];
    let right_operand = &state[right];
    let union = global_axis_order
        .iter()
        .copied()
        .filter(|&axis| {
            model_axis_extent(left_operand, axis).is_some()
                || model_axis_extent(right_operand, axis).is_some()
        })
        .collect::<Vec<_>>();
    let retained = union
        .iter()
        .copied()
        .filter(|&axis| {
            final_output.contains(&axis)
                || state.iter().enumerate().any(|(index, operand)| {
                    index != left && index != right && model_axis_extent(operand, axis).is_some()
                })
        })
        .collect::<Vec<_>>();
    let resolve = |axis| match (
        model_axis_extent(left_operand, axis),
        model_axis_extent(right_operand, axis),
    ) {
        (Some(left), Some(right)) => resolve_extent(&axis.display_name(), left, right),
        (Some(extent), None) | (None, Some(extent)) => Ok(extent),
        (None, None) => candle_core::bail!("n-ary model axis is absent from both operands"),
    };
    let left_axes = left_operand
        .axes
        .iter()
        .map(|(axis, _)| *axis)
        .collect::<Vec<_>>();
    let left_dims = left_operand
        .axes
        .iter()
        .map(|(_, extent)| *extent)
        .collect::<Vec<_>>();
    let right_axes = right_operand
        .axes
        .iter()
        .map(|(axis, _)| *axis)
        .collect::<Vec<_>>();
    let right_dims = right_operand
        .axes
        .iter()
        .map(|(_, extent)| *extent)
        .collect::<Vec<_>>();
    let graph = classify_expanded_binary_graph(
        BinaryGraphOperand {
            axes: &left_axes,
            dims: &left_dims,
            layout: left_operand.layout.as_binary(),
        },
        BinaryGraphOperand {
            axes: &right_axes,
            dims: &right_dims,
            layout: right_operand.layout.as_binary(),
        },
        &retained,
        4,
    )?;
    let classification = graph.plan;
    let canonical_axes = classification
        .batch
        .iter()
        .chain(&classification.left_free)
        .chain(&classification.right_free)
        .copied()
        .collect::<Vec<_>>();
    let axes = canonical_axes
        .iter()
        .copied()
        .map(|axis| resolve(axis).map(|extent| (axis, extent)))
        .collect::<Result<Vec<_>>>()?;
    Ok((
        NaryPairCost {
            flops: graph.work,
            output_elements: graph.output_elements,
            copy_bytes: graph.copy_bytes,
            submissions: graph.submissions,
        },
        NaryPlannerMetadata {
            stable_ordinal: left_operand
                .stable_ordinal
                .min(right_operand.stable_ordinal),
            axes,
            layout: graph.output_layout,
            members: left_operand.members | right_operand.members,
        },
    ))
}

fn model_initial_metrics(state: &[NaryPlannerMetadata<'_>]) -> Result<NaryPlanMetrics> {
    let peak_live_elements = state.iter().try_fold(0_u128, |sum, operand| {
        sum.checked_add(operand.elements()?)
            .ok_or_else(|| candle_core::Error::msg("n-ary live estimate overflows u128"))
    })?;
    Ok(NaryPlanMetrics {
        flops: 0,
        intermediate_elements: 0,
        output_elements: 0,
        copy_bytes: 0,
        peak_live_elements,
        submissions: 0,
        score: 0,
    })
}

fn model_accumulate(
    metrics: &mut NaryPlanMetrics,
    state: &[NaryPlannerMetadata<'_>],
    estimate: &NaryPairCost,
) -> Result<()> {
    let live = state.iter().try_fold(0_u128, |sum, operand| {
        sum.checked_add(operand.elements()?)
            .ok_or_else(|| candle_core::Error::msg("n-ary live estimate overflows u128"))
    })?;
    metrics.peak_live_elements = metrics.peak_live_elements.max(
        live.checked_add(estimate.output_elements)
            .ok_or_else(|| candle_core::Error::msg("n-ary peak estimate overflows u128"))?,
    );
    metrics.flops = metrics
        .flops
        .checked_add(estimate.flops)
        .ok_or_else(|| candle_core::Error::msg("n-ary FLOP estimate overflows u128"))?;
    metrics.intermediate_elements = metrics
        .intermediate_elements
        .checked_add(estimate.output_elements)
        .ok_or_else(|| candle_core::Error::msg("n-ary intermediate estimate overflows u128"))?;
    metrics.copy_bytes = metrics
        .copy_bytes
        .checked_add(estimate.copy_bytes)
        .ok_or_else(|| candle_core::Error::msg("n-ary copy estimate overflows u128"))?;
    metrics.submissions = metrics
        .submissions
        .checked_add(estimate.submissions)
        .ok_or_else(|| candle_core::Error::msg("n-ary submission estimate overflows u128"))?;
    metrics.output_elements = estimate.output_elements;
    Ok(())
}

fn model_score(metrics: &NaryPlanMetrics) -> Result<u128> {
    [
        (metrics.flops, 1),
        (metrics.copy_bytes, 1),
        (metrics.intermediate_elements, 2),
        (metrics.peak_live_elements, 2),
        (metrics.submissions, 1_024),
    ]
    .into_iter()
    .try_fold(0_u128, |sum, (value, weight)| {
        sum.checked_add(
            value
                .checked_mul(weight)
                .ok_or_else(|| candle_core::Error::msg("n-ary weighted estimate overflows u128"))?,
        )
        .ok_or_else(|| candle_core::Error::msg("n-ary score estimate overflows u128"))
    })
}

fn model_apply_pair<'a>(
    state: &mut Vec<NaryPlannerMetadata<'a>>,
    left: usize,
    right: usize,
    output: NaryPlannerMetadata<'a>,
) {
    state.remove(right);
    state.remove(left);
    state.insert(left, output);
}

fn model_greedy_plan<'a>(
    operands: &[NaryPlannerMetadata<'a>],
    final_output: &[ExpandedAxis<'a>],
    global: &[ExpandedAxis<'a>],
) -> Result<NaryContractionPlan<'a>> {
    let mut state = operands.to_vec();
    let mut metrics = model_initial_metrics(&state)?;
    let mut steps = Vec::new();
    while state.len() > 1 {
        let mut best = None;
        for left in 0..state.len() - 1 {
            for right in left + 1..state.len() {
                let (estimate, output) =
                    model_pair_details(&state, left, right, final_output, global)?;
                let key = (
                    estimate.output_elements,
                    estimate.flops,
                    state[left].stable_ordinal,
                    state[right].stable_ordinal,
                    left,
                    right,
                );
                if best.as_ref().is_none_or(
                    |(bl, br, be, _): &(usize, usize, NaryPairCost, NaryPlannerMetadata<'a>)| {
                        key < (
                            be.output_elements,
                            be.flops,
                            state[*bl].stable_ordinal,
                            state[*br].stable_ordinal,
                            *bl,
                            *br,
                        )
                    },
                ) {
                    best = Some((left, right, estimate, output));
                }
            }
        }
        let (left, right, estimate, output) =
            best.ok_or_else(|| candle_core::Error::msg("n-ary greedy model found no pair"))?;
        model_accumulate(&mut metrics, &state, &estimate)?;
        steps.push(NaryPlanStep {
            members: (state[left].members, state[right].members),
            output_axes: output.axes.iter().map(|(axis, _)| *axis).collect(),
            estimate,
        });
        model_apply_pair(&mut state, left, right, output);
    }
    metrics.score = model_score(&metrics)?;
    Ok(NaryContractionPlan { steps, metrics })
}

fn model_sequence_plan<'a>(
    operands: &[NaryPlannerMetadata<'a>],
    final_output: &[ExpandedAxis<'a>],
    global: &[ExpandedAxis<'a>],
    sequence: &[(u64, u64)],
) -> Result<NaryContractionPlan<'a>> {
    if sequence.len() + 1 != operands.len() {
        candle_core::bail!("cached n-ary sequence has the wrong number of steps")
    }
    let mut state = operands.to_vec();
    let mut metrics = model_initial_metrics(&state)?;
    let mut steps = Vec::with_capacity(sequence.len());
    for &members in sequence {
        let left = state
            .iter()
            .position(|operand| operand.members == members.0)
            .ok_or_else(|| candle_core::Error::msg("cached n-ary left members are not live"))?;
        let right = state
            .iter()
            .position(|operand| operand.members == members.1)
            .ok_or_else(|| candle_core::Error::msg("cached n-ary right members are not live"))?;
        if left >= right {
            candle_core::bail!("cached n-ary members are not in stable order")
        }
        let (estimate, pair_output) =
            model_pair_details(&state, left, right, final_output, global)?;
        model_accumulate(&mut metrics, &state, &estimate)?;
        steps.push(NaryPlanStep {
            members,
            output_axes: pair_output.axes.iter().map(|(axis, _)| *axis).collect(),
            estimate,
        });
        model_apply_pair(&mut state, left, right, pair_output);
    }
    metrics.score = model_score(&metrics)?;
    Ok(NaryContractionPlan { steps, metrics })
}

fn model_exact_search<'a>(
    operands: &[NaryPlannerMetadata<'a>],
    final_output: &[ExpandedAxis<'a>],
    global: &[ExpandedAxis<'a>],
) -> Result<NaryContractionPlan<'a>> {
    fn visit<'a>(
        state: Vec<NaryPlannerMetadata<'a>>,
        steps: Vec<NaryPlanStep<'a>>,
        metrics: NaryPlanMetrics,
        output: &[ExpandedAxis<'a>],
        global: &[ExpandedAxis<'a>],
        best: &mut Option<NaryContractionPlan<'a>>,
    ) -> Result<()> {
        if state.len() == 1 {
            let mut metrics = metrics;
            metrics.score = model_score(&metrics)?;
            let candidate = NaryContractionPlan { steps, metrics };
            let masks = |plan: &NaryContractionPlan<'a>| {
                plan.steps
                    .iter()
                    .map(|step| step.members)
                    .collect::<Vec<_>>()
            };
            if best.as_ref().is_none_or(|current| {
                (candidate.metrics.score, masks(&candidate))
                    < (current.metrics.score, masks(current))
            }) {
                *best = Some(candidate);
            }
            return Ok(());
        }
        for left in 0..state.len() - 1 {
            for right in left + 1..state.len() {
                let (estimate, pair_output) =
                    model_pair_details(&state, left, right, output, global)?;
                let mut next_state = state.clone();
                let mut next_metrics = metrics.clone();
                model_accumulate(&mut next_metrics, &state, &estimate)?;
                let mut next_steps = steps.clone();
                next_steps.push(NaryPlanStep {
                    members: (state[left].members, state[right].members),
                    output_axes: pair_output.axes.iter().map(|(axis, _)| *axis).collect(),
                    estimate,
                });
                model_apply_pair(&mut next_state, left, right, pair_output);
                visit(next_state, next_steps, next_metrics, output, global, best)?;
            }
        }
        Ok(())
    }
    if !(3..=4).contains(&operands.len()) {
        candle_core::bail!("exact n-ary planner supports arity 3 through 4")
    }
    let metrics = model_initial_metrics(operands)?;
    let mut best = None;
    visit(
        operands.to_vec(),
        Vec::new(),
        metrics,
        final_output,
        global,
        &mut best,
    )?;
    best.ok_or_else(|| candle_core::Error::msg("exact n-ary planner found no plan"))
}

fn select_layout_aware_plan<'a>(
    operands: &[NaryPlannerMetadata<'a>],
    final_output: &[ExpandedAxis<'a>],
    dtype: DType,
    cpu: bool,
) -> NaryPlannerDecision<'a> {
    if !(3..=4).contains(&operands.len()) {
        return NaryPlannerDecision::Greedy(NaryGreedyReason::Arity);
    }
    if dtype != DType::F32 {
        return NaryPlannerDecision::Greedy(NaryGreedyReason::DType);
    }
    if !cpu {
        return NaryPlannerDecision::Greedy(NaryGreedyReason::Backend);
    }
    if operands
        .iter()
        .any(|operand| operand.layout == NaryLayoutEstimate::Unsupported)
    {
        return NaryPlannerDecision::Greedy(NaryGreedyReason::UnsupportedLayout);
    }
    if operands
        .iter()
        .any(|operand| operand.axes.iter().any(|(_, extent)| *extent == 0))
    {
        return NaryPlannerDecision::Greedy(NaryGreedyReason::BelowFlopThreshold);
    }
    if !EXACT_NARY_EXECUTION_CALIBRATED {
        return NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration);
    }
    let mut global = Vec::new();
    for operand in operands {
        for &(axis, _) in &operand.axes {
            if !global.contains(&axis) {
                global.push(axis);
            }
        }
    }
    let cache_key = nary_plan_cache_key(operands, final_output);
    if let Some(sequence) = cached_nary_sequence(&cache_key)
        && let Ok(plan) = model_sequence_plan(operands, final_output, &global, &sequence)
    {
        return NaryPlannerDecision::Exact(plan);
    }
    let greedy = match model_greedy_plan(operands, final_output, &global) {
        Ok(plan) => plan,
        Err(_) => return NaryPlannerDecision::Greedy(NaryGreedyReason::ModelFailure),
    };
    if greedy.metrics.flops < 100_000 {
        return NaryPlannerDecision::Greedy(NaryGreedyReason::BelowFlopThreshold);
    }
    match model_exact_search(operands, final_output, &global) {
        Ok(plan) => {
            cache_nary_sequence(
                cache_key,
                plan.steps.iter().map(|step| step.members).collect(),
            );
            NaryPlannerDecision::Exact(plan)
        }
        Err(_) => NaryPlannerDecision::Greedy(NaryGreedyReason::ModelFailure),
    }
}

#[cfg(test)]
fn select_layout_aware_plan_for_test<'a>(
    operands: &[NaryPlannerMetadata<'a>],
    final_output: &[&'a str],
    dtype: DType,
    cpu: bool,
) -> NaryPlannerDecision<'a> {
    select_layout_aware_plan(
        operands,
        &final_output
            .iter()
            .copied()
            .map(ExpandedAxis::Named)
            .collect::<Vec<_>>(),
        dtype,
        cpu,
    )
}

#[cfg(test)]
fn plan_layout_exact_for_test<'a>(
    operands: &[NaryPlannerMetadata<'a>],
    final_output: &[&'a str],
) -> Result<NaryContractionPlan<'a>> {
    let mut global = Vec::new();
    for operand in operands {
        for &(axis, _) in &operand.axes {
            if !global.contains(&axis) {
                global.push(axis);
            }
        }
    }
    model_exact_search(
        operands,
        &final_output
            .iter()
            .copied()
            .map(ExpandedAxis::Named)
            .collect::<Vec<_>>(),
        &global,
    )
}

#[derive(Debug)]
struct PairEstimate<'a> {
    left: usize,
    right: usize,
    output_axes: Vec<ExpandedAxis<'a>>,
    output_elements: u128,
    flops: u128,
}

fn stable_axis_order<'a>(operands: &[PlannedOperand<'a>]) -> Vec<ExpandedAxis<'a>> {
    let mut axes = Vec::new();
    let mut ordered = operands.iter().collect::<Vec<_>>();
    ordered.sort_by_key(|operand| operand.stable_ordinal);
    for operand in ordered {
        for &axis in &operand.axes {
            if !axes.contains(&axis) {
                axes.push(axis);
            }
        }
    }
    axes
}

fn validate_nary_broadcasts(operands: &[PlannedOperand<'_>]) -> Result<()> {
    let mut dimensions = Vec::<(ExpandedAxis<'_>, usize)>::new();
    for operand in operands {
        for (&axis, &extent) in operand.axes.iter().zip(operand.tensor.dims()) {
            if let Some((_, resolved)) = dimensions
                .iter_mut()
                .find(|(candidate, _)| *candidate == axis)
            {
                *resolved = resolve_extent(&axis.display_name(), *resolved, extent)?;
            } else {
                dimensions.push((axis, extent));
            }
        }
    }
    Ok(())
}

#[cfg(test)]
fn select_nary_pair<'a>(
    operands: &[PlannedOperand<'a>],
    final_output: &[ExpandedAxis<'a>],
) -> Result<PairEstimate<'a>> {
    let global_axis_order = stable_axis_order(operands);
    select_nary_pair_with_order(operands, final_output, &global_axis_order)
}

fn select_nary_pair_with_order<'a>(
    operands: &[PlannedOperand<'a>],
    final_output: &[ExpandedAxis<'a>],
    global_axis_order: &[ExpandedAxis<'a>],
) -> Result<PairEstimate<'a>> {
    if operands.len() < 2 {
        candle_core::bail!("invalid n-ary einsum planner state: fewer than two operands")
    }
    let mut best: Option<PairEstimate<'a>> = None;
    for left in 0..operands.len() - 1 {
        for right in left + 1..operands.len() {
            let candidate =
                estimate_pair_with_order(operands, left, right, final_output, global_axis_order)?;
            let candidate_key = (
                candidate.output_elements,
                candidate.flops,
                operands[left].stable_ordinal,
                operands[right].stable_ordinal,
                left,
                right,
            );
            let replace = best.as_ref().is_none_or(|current| {
                candidate_key
                    < (
                        current.output_elements,
                        current.flops,
                        operands[current.left].stable_ordinal,
                        operands[current.right].stable_ordinal,
                        current.left,
                        current.right,
                    )
            });
            if replace {
                best = Some(candidate);
            }
        }
    }
    best.ok_or_else(|| candle_core::Error::msg("n-ary einsum planner found no operand pair"))
}

#[cfg(test)]
fn estimate_pair<'a>(
    operands: &[PlannedOperand<'a>],
    left: usize,
    right: usize,
    final_output: &[ExpandedAxis<'a>],
) -> Result<PairEstimate<'a>> {
    let global_axis_order = stable_axis_order(operands);
    estimate_pair_with_order(operands, left, right, final_output, &global_axis_order)
}

fn estimate_pair_with_order<'a>(
    operands: &[PlannedOperand<'a>],
    left: usize,
    right: usize,
    final_output: &[ExpandedAxis<'a>],
    global_axis_order: &[ExpandedAxis<'a>],
) -> Result<PairEstimate<'a>> {
    let left_operand = operands.get(left).ok_or_else(|| {
        candle_core::Error::msg(format!(
            "n-ary einsum planner left index {left} is out of range"
        ))
    })?;
    let right_operand = operands.get(right).ok_or_else(|| {
        candle_core::Error::msg(format!(
            "n-ary einsum planner right index {right} is out of range"
        ))
    })?;
    if left >= right {
        candle_core::bail!("n-ary einsum planner pair must be ordered, received ({left}, {right})")
    }

    let mut pair_axes = Vec::new();
    for &axis in left_operand.axes.iter().chain(&right_operand.axes) {
        if !pair_axes.contains(&axis) {
            pair_axes.push(axis);
        }
    }
    let mut live_axes = final_output.to_vec();
    for (index, operand) in operands.iter().enumerate() {
        if index != left && index != right {
            for &axis in &operand.axes {
                if !live_axes.contains(&axis) {
                    live_axes.push(axis);
                }
            }
        }
    }
    let output_axes = global_axis_order
        .iter()
        .copied()
        .filter(|axis| pair_axes.contains(axis) && live_axes.contains(axis))
        .collect::<Vec<_>>();
    let output_extents = output_axes
        .iter()
        .map(|axis| pair_axis_extent(left_operand, right_operand, *axis))
        .collect::<Result<Vec<_>>>()?;
    let flop_extents = pair_axes
        .iter()
        .map(|axis| pair_axis_extent(left_operand, right_operand, *axis))
        .collect::<Result<Vec<_>>>()?;
    let output_elements = checked_nary_product(&output_extents).map_err(|error| {
        error.context(format!(
            "einsum n-ary pair ({left}, {right}) intermediate estimate"
        ))
    })?;
    let flops = checked_nary_product(&flop_extents).map_err(|error| {
        error.context(format!("einsum n-ary pair ({left}, {right}) FLOP estimate"))
    })?;
    Ok(PairEstimate {
        left,
        right,
        output_axes,
        output_elements,
        flops,
    })
}

fn pair_axis_extent(
    left: &PlannedOperand<'_>,
    right: &PlannedOperand<'_>,
    axis: ExpandedAxis<'_>,
) -> Result<usize> {
    let left_extent = left
        .axes
        .iter()
        .position(|candidate| *candidate == axis)
        .map(|position| left.tensor.dims()[position]);
    let right_extent = right
        .axes
        .iter()
        .position(|candidate| *candidate == axis)
        .map(|position| right.tensor.dims()[position]);
    match (left_extent, right_extent) {
        (Some(left), Some(right)) => resolve_extent(&axis.display_name(), left, right),
        (Some(extent), None) | (None, Some(extent)) => Ok(extent),
        (None, None) => candle_core::bail!(
            "invalid n-ary einsum planner axis `{}` is absent from both operands",
            axis.display_name()
        ),
    }
}

fn checked_nary_product(extents: &[usize]) -> Result<u128> {
    if extents.contains(&0) {
        return Ok(0);
    }
    extents.iter().try_fold(1_u128, |product, &extent| {
        product
            .checked_mul(extent as u128)
            .ok_or_else(|| candle_core::Error::msg("einsum n-ary cost estimate overflows u128"))
    })
}

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
enum ExpandedAxis<'a> {
    Named(&'a str),
    Ellipsis(usize),
}

impl ExpandedAxis<'_> {
    fn display_name(&self) -> String {
        match self {
            Self::Named(name) => (*name).to_owned(),
            Self::Ellipsis(index) => format!("..[{index}]"),
        }
    }
}

fn ellipsis_capture(
    operand: &Tensor,
    operand_index: usize,
    pattern: EinsumAxisPattern<'_>,
) -> Result<usize> {
    if let Some(position) = pattern.ellipsis_position {
        if position > pattern.labels.len() {
            candle_core::bail!(
                "invalid ellipsis einsum plan: operand {operand_index} ellipsis position {position} exceeds {} explicit labels",
                pattern.labels.len()
            )
        }
        operand.rank().checked_sub(pattern.labels.len()).ok_or_else(|| {
            candle_core::Error::msg(format!(
                "einsum operand {operand_index} has rank {}, but {} explicit axes leave no valid ellipsis capture",
                operand.rank(),
                pattern.labels.len()
            ))
        })
    } else if operand.rank() == pattern.labels.len() {
        Ok(0)
    } else {
        candle_core::bail!(
            "einsum operand {operand_index} has rank {}, expected {} because its axis list has no ellipsis",
            operand.rank(),
            pattern.labels.len()
        )
    }
}

fn normalize_ellipsis_operand(
    operand: &Tensor,
    pattern: EinsumAxisPattern<'_>,
    capture: usize,
    maximum_capture: usize,
    operand_index: usize,
) -> Result<Tensor> {
    let missing = maximum_capture.checked_sub(capture).ok_or_else(|| {
        candle_core::Error::msg("invalid ellipsis einsum plan: capture exceeds maximum")
    })?;
    let insertion = pattern.ellipsis_position.unwrap_or(0);
    let mut normalized = operand.clone();
    for _ in 0..missing {
        normalized = normalized.unsqueeze(insertion).map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} ellipsis right-alignment"
            ))
        })?;
    }
    Ok(normalized)
}

#[derive(Debug, PartialEq, Eq)]
enum RepeatedAxisLoweringPlan {
    Sequential,
    OriginalFlatGather {
        output_shape: Vec<usize>,
        offsets: Vec<u32>,
    },
}

/// Caller-owned, device-bound indices for repeated-axis diagonal extraction.
///
/// Axis ids represent the input side of an einsum equation: equal ids are the
/// repeated labels whose diagonal is retained, and first occurrence order
/// determines the output axes. Preparing once avoids rebuilding and uploading
/// the same `u32` index tensor for repeated calls with the same shape.
#[derive(Debug)]
pub struct PreparedDiagonalPlan {
    input_shape: Vec<usize>,
    axis_ids: Vec<usize>,
    output_shape: Vec<usize>,
    indices: Tensor,
}

impl PreparedDiagonalPlan {
    /// Prepares reusable diagonal indices for one exact shape and device.
    pub fn new(input_shape: &[usize], axis_ids: &[usize], device: &Device) -> Result<Self> {
        if input_shape.len() != axis_ids.len() {
            candle_core::bail!(
                "prepared diagonal shape rank {} does not match axis-id rank {}",
                input_shape.len(),
                axis_ids.len()
            )
        }
        let axes = axis_ids
            .iter()
            .copied()
            .map(ExpandedAxis::Ellipsis)
            .collect::<Vec<_>>();
        validate_repeated_extents(input_shape, &axes, 0)?;
        if !(0..axis_ids.len()).any(|position| axis_ids[..position].contains(&axis_ids[position])) {
            candle_core::bail!("prepared diagonal plan requires at least one repeated axis id")
        }
        let Some((output_shape, offsets)) = original_flat_gather_offsets(input_shape, &axes, 0)?
        else {
            candle_core::bail!("prepared diagonal offsets exceed the supported u32 index range")
        };
        let index_count = offsets.len();
        let indices = Tensor::from_vec(offsets, index_count, device)
            .map_err(|error| error.context("prepared diagonal device-local indices"))?;
        Ok(Self {
            input_shape: input_shape.to_vec(),
            axis_ids: axis_ids.to_vec(),
            output_shape,
            indices,
        })
    }

    /// Convenience constructor for `i i ... -> i` extraction.
    pub fn repeated(extent: usize, multiplicity: usize, device: &Device) -> Result<Self> {
        if multiplicity < 2 {
            candle_core::bail!("prepared repeated diagonal requires multiplicity of at least two")
        }
        Self::new(&vec![extent; multiplicity], &vec![0; multiplicity], device)
    }

    /// Convenience constructor for `i j i j -> i j` extraction.
    pub fn interleaved(first_extent: usize, second_extent: usize, device: &Device) -> Result<Self> {
        Self::new(
            &[first_extent, second_extent, first_extent, second_extent],
            &[0, 1, 0, 1],
            device,
        )
    }

    /// Extracts the prepared diagonal from one contiguous tensor.
    pub fn execute(&self, input: &Tensor) -> Result<Tensor> {
        if input.dims() != self.input_shape {
            candle_core::bail!(
                "prepared diagonal plan expects shape {:?}, received {:?}",
                self.input_shape,
                input.dims()
            )
        }
        if !input.is_contiguous() {
            candle_core::bail!("prepared diagonal plan requires contiguous input")
        }
        if !input.device().same_device(self.indices.device()) {
            candle_core::bail!("prepared diagonal plan and input are on different devices")
        }
        input
            .flatten_all()
            .and_then(|flat| flat.index_select(&self.indices, 0))
            .and_then(|selected| selected.reshape(self.output_shape.as_slice()))
            .map_err(|error| error.context("prepared diagonal extraction"))
    }

    /// Exact input shape captured by this plan.
    #[must_use]
    pub fn input_shape(&self) -> &[usize] {
        &self.input_shape
    }

    /// Axis ids captured from the input-side equation.
    #[must_use]
    pub fn axis_ids(&self) -> &[usize] {
        &self.axis_ids
    }

    /// Unique-axis output shape in first-occurrence order.
    #[must_use]
    pub fn output_shape(&self) -> &[usize] {
        &self.output_shape
    }

    /// Device index representation used by the prepared gather.
    #[must_use]
    pub const fn index_dtype(&self) -> DType {
        DType::U32
    }

    /// Prepared device-local indices, exposed for diagnostics and benchmarking.
    #[must_use]
    pub fn indices(&self) -> &Tensor {
        &self.indices
    }
}

fn validate_repeated_extents(
    dims: &[usize],
    axes: &[ExpandedAxis<'_>],
    operand_index: usize,
) -> Result<()> {
    for (position, axis) in axes.iter().copied().enumerate() {
        let Some(previous) = axes[..position]
            .iter()
            .position(|candidate| *candidate == axis)
        else {
            continue;
        };
        let extent = dims[previous];
        let other = dims[position];
        if other != extent {
            candle_core::bail!(
                "einsum operand {operand_index} repeated label `{}` has unequal extents {extent} and {other}",
                axis.display_name()
            )
        }
    }
    Ok(())
}

fn checked_contiguous_strides(dims: &[usize]) -> Option<Vec<usize>> {
    let mut product = 1_usize;
    let mut strides = vec![0; dims.len()];
    for (position, &extent) in dims.iter().enumerate().rev() {
        strides[position] = product;
        product = product.checked_mul(extent)?;
    }
    Some(strides)
}

fn simulated_contiguous(dims: &[usize], strides: &[usize]) -> Option<bool> {
    let mut expected = 1_usize;
    for (&extent, &stride) in dims.iter().zip(strides).rev() {
        if extent > 1 && stride != expected {
            return Some(false);
        }
        expected = expected.checked_mul(extent)?;
    }
    Some(true)
}

fn sequential_diagonal_would_materialize(
    original_dims: &[usize],
    original_axes: &[ExpandedAxis<'_>],
) -> Option<bool> {
    let mut dims = original_dims.to_vec();
    let mut axes = original_axes.to_vec();
    let mut strides = checked_contiguous_strides(&dims)?;
    loop {
        let Some(repeated_axis) = axes
            .iter()
            .copied()
            .find(|axis| axes.iter().filter(|candidate| **candidate == *axis).count() > 1)
        else {
            return Some(false);
        };
        let positions = axes
            .iter()
            .enumerate()
            .filter_map(|(position, axis)| (*axis == repeated_axis).then_some(position))
            .collect::<Vec<_>>();
        let other_positions = (0..axes.len())
            .filter(|position| !positions.contains(position))
            .collect::<Vec<_>>();
        let permutation = positions
            .iter()
            .chain(&other_positions)
            .copied()
            .collect::<Vec<_>>();
        let adjacent_dims = permutation
            .iter()
            .map(|&position| dims[position])
            .collect::<Vec<_>>();
        let adjacent_strides = permutation
            .iter()
            .map(|&position| strides[position])
            .collect::<Vec<_>>();
        if !simulated_contiguous(&adjacent_dims, &adjacent_strides)? {
            return Some(true);
        }

        let selected_dims = std::iter::once(dims[positions[0]])
            .chain(other_positions.iter().map(|&position| dims[position]))
            .collect::<Vec<_>>();
        let selected_strides = checked_contiguous_strides(&selected_dims)?;
        let result_order = std::iter::once(positions[0])
            .chain(other_positions.iter().copied())
            .collect::<Vec<_>>();
        let desired_order = (0..axes.len())
            .filter(|position| !positions[1..].contains(position))
            .collect::<Vec<_>>();
        let restoration = desired_order
            .iter()
            .map(|position| {
                result_order
                    .iter()
                    .position(|candidate| candidate == position)
            })
            .collect::<Option<Vec<_>>>()?;
        dims = restoration
            .iter()
            .map(|&position| selected_dims[position])
            .collect();
        strides = restoration
            .iter()
            .map(|&position| selected_strides[position])
            .collect();
        axes = desired_order
            .iter()
            .map(|&position| axes[position])
            .collect();
    }
}

fn sequential_adjacency_is_always_identity(original_axes: &[ExpandedAxis<'_>]) -> bool {
    if original_axes
        .first()
        .is_some_and(|first| original_axes.iter().all(|axis| axis == first))
    {
        return true;
    }
    let mut axes = original_axes.to_vec();
    loop {
        let Some(repeated_axis) = axes
            .iter()
            .copied()
            .find(|axis| axes.iter().filter(|candidate| **candidate == *axis).count() > 1)
        else {
            return true;
        };
        let positions = axes
            .iter()
            .enumerate()
            .filter_map(|(position, axis)| (*axis == repeated_axis).then_some(position))
            .collect::<Vec<_>>();
        if positions.iter().copied().ne(0..positions.len()) {
            return false;
        }
        axes = axes
            .iter()
            .enumerate()
            .filter_map(|(position, axis)| (!positions[1..].contains(&position)).then_some(*axis))
            .collect();
    }
}

fn original_flat_gather_offsets(
    dims: &[usize],
    axes: &[ExpandedAxis<'_>],
    operand_index: usize,
) -> Result<Option<(Vec<usize>, Vec<u32>)>> {
    let mut unique_axes = Vec::new();
    let mut unique_positions = Vec::with_capacity(axes.len());
    for axis in axes.iter().copied() {
        let position =
            if let Some(position) = unique_axes.iter().position(|candidate| *candidate == axis) {
                position
            } else {
                unique_axes.push(axis);
                unique_axes.len() - 1
            };
        unique_positions.push(position);
    }
    let output_shape = unique_axes
        .iter()
        .map(|axis| {
            let position = axes
                .iter()
                .position(|candidate| candidate == axis)
                .expect("a unique diagonal axis came from the original axes");
            dims[position]
        })
        .collect::<Vec<_>>();

    if output_shape.contains(&0) {
        return Ok(Some((output_shape, Vec::new())));
    }
    let Some(original_strides) = checked_contiguous_strides(dims) else {
        return Ok(None);
    };
    let Some(output_elements) = output_shape
        .iter()
        .try_fold(1_usize, |product, &extent| product.checked_mul(extent))
    else {
        return Ok(None);
    };
    let mut maximum_offset = 0_usize;
    for (position, &stride) in original_strides.iter().enumerate() {
        let coordinate = output_shape[unique_positions[position]] - 1;
        let Some(contribution) = coordinate.checked_mul(stride) else {
            return Ok(None);
        };
        let Some(next) = maximum_offset.checked_add(contribution) else {
            return Ok(None);
        };
        maximum_offset = next;
    }
    if maximum_offset >= u32::MAX as usize {
        return Ok(None);
    }

    let Some(output_strides) = checked_contiguous_strides(&output_shape) else {
        return Ok(None);
    };
    let mut offsets = Vec::new();
    offsets
        .try_reserve_exact(output_elements)
        .map_err(|error| {
            candle_core::Error::msg(format!(
                "einsum operand {operand_index} diagonal offset allocation failed: {error}"
            ))
        })?;
    for output_index in 0..output_elements {
        let mut offset = 0_usize;
        for (position, &stride) in original_strides.iter().enumerate() {
            let unique_position = unique_positions[position];
            let coordinate =
                (output_index / output_strides[unique_position]) % output_shape[unique_position];
            offset += coordinate * stride;
        }
        offsets.push(u32::try_from(offset).expect("maximum checked original-layout offset"));
    }
    Ok(Some((output_shape, offsets)))
}

fn plan_repeated_axis_lowering(
    dims: &[usize],
    axes: &[ExpandedAxis<'_>],
    original_contiguous: bool,
    operand_index: usize,
) -> Result<RepeatedAxisLoweringPlan> {
    validate_repeated_extents(dims, axes, operand_index)?;
    if !original_contiguous
        || sequential_adjacency_is_always_identity(axes)
        || sequential_diagonal_would_materialize(dims, axes) != Some(true)
    {
        return Ok(RepeatedAxisLoweringPlan::Sequential);
    }
    let Some((output_shape, offsets)) = original_flat_gather_offsets(dims, axes, operand_index)?
    else {
        return Ok(RepeatedAxisLoweringPlan::Sequential);
    };
    Ok(RepeatedAxisLoweringPlan::OriginalFlatGather {
        output_shape,
        offsets,
    })
}

fn original_flat_diagonal_gather(
    operand: &Tensor,
    output_shape: &[usize],
    offsets: Vec<u32>,
    operand_index: usize,
) -> Result<Tensor> {
    let index_count = offsets.len();
    let indices = Tensor::from_vec(offsets, index_count, operand.device()).map_err(|error| {
        error.context(format!(
            "einsum operand {operand_index} device-local combined diagonal indices"
        ))
    })?;
    operand
        .flatten_all()
        .map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} original-layout diagonal flatten"
            ))
        })?
        .index_select(&indices, 0)
        .map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} differentiable combined diagonal selection"
            ))
        })?
        .reshape(output_shape)
        .map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} combined diagonal reshape"
            ))
        })
}

fn normalize_repeated_axes<'a>(
    mut operand: Tensor,
    mut axes: Vec<ExpandedAxis<'a>>,
    operand_index: usize,
) -> Result<(Tensor, Vec<ExpandedAxis<'a>>)> {
    match plan_repeated_axis_lowering(
        operand.dims(),
        &axes,
        operand.is_contiguous(),
        operand_index,
    )? {
        RepeatedAxisLoweringPlan::Sequential => {}
        RepeatedAxisLoweringPlan::OriginalFlatGather {
            output_shape,
            offsets,
        } => {
            let mut unique_axes = Vec::new();
            for axis in axes {
                if !unique_axes.contains(&axis) {
                    unique_axes.push(axis);
                }
            }
            return Ok((
                original_flat_diagonal_gather(&operand, &output_shape, offsets, operand_index)?,
                unique_axes,
            ));
        }
    }
    loop {
        let Some(repeated_axis) = axes
            .iter()
            .copied()
            .find(|axis| axes.iter().filter(|candidate| **candidate == *axis).count() > 1)
        else {
            return Ok((operand, axes));
        };
        let positions = axes
            .iter()
            .enumerate()
            .filter_map(|(position, axis)| (*axis == repeated_axis).then_some(position))
            .collect::<Vec<_>>();
        let extent = operand.dims()[positions[0]];

        let other_positions = (0..axes.len())
            .filter(|position| !positions.contains(position))
            .collect::<Vec<_>>();
        let adjacency_permutation = positions
            .iter()
            .chain(&other_positions)
            .copied()
            .collect::<Vec<_>>();
        let device = operand.device().clone();
        let adjacent = if adjacency_permutation.iter().copied().eq(0..axes.len()) {
            operand
        } else {
            operand
                .permute(adjacency_permutation.as_slice())
                .map_err(|error| {
                    error.context(format!(
                        "einsum operand {operand_index} diagonal adjacency permutation"
                    ))
                })?
        };

        let (repeated_flat_extent, diagonal_stride) =
            checked_diagonal_layout(extent, positions.len(), operand_index)?;
        let mut flattened_shape = vec![repeated_flat_extent];
        flattened_shape.extend_from_slice(&adjacent.dims()[positions.len()..]);
        let flattened = adjacent.reshape(flattened_shape).map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} repeated-axis flatten"
            ))
        })?;

        let mut diagonal_indices = Vec::with_capacity(extent);
        for coordinate in 0..extent {
            let index = coordinate.checked_mul(diagonal_stride).ok_or_else(|| {
                candle_core::Error::msg(format!(
                    "einsum operand {operand_index} diagonal index overflows usize"
                ))
            })?;
            diagonal_indices.push(u32::try_from(index).map_err(|_| {
                candle_core::Error::msg(format!(
                    "einsum operand {operand_index} diagonal index {index} exceeds u32"
                ))
            })?);
        }
        let indices = Tensor::from_vec(diagonal_indices, extent, &device).map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} device-local diagonal indices"
            ))
        })?;
        let selected = flattened.index_select(&indices, 0).map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} differentiable diagonal selection"
            ))
        })?;

        let result_order = std::iter::once(positions[0])
            .chain(other_positions.iter().copied())
            .collect::<Vec<_>>();
        let desired_order = (0..axes.len())
            .filter(|position| !positions[1..].contains(position))
            .collect::<Vec<_>>();
        let restoration = desired_order
            .iter()
            .map(|position| {
                result_order
                    .iter()
                    .position(|candidate| candidate == position)
                    .expect("diagonal result order contains every surviving axis")
            })
            .collect::<Vec<_>>();
        operand = if restoration.iter().copied().eq(0..restoration.len()) {
            selected
        } else {
            selected.permute(restoration.as_slice()).map_err(|error| {
                error.context(format!(
                    "einsum operand {operand_index} diagonal axis restoration"
                ))
            })?
        };
        axes = desired_order
            .iter()
            .map(|&position| axes[position])
            .collect();
    }
}

fn checked_diagonal_layout(
    extent: usize,
    multiplicity: usize,
    operand_index: usize,
) -> Result<(usize, usize)> {
    let mut diagonal_stride = 0_usize;
    let mut power = 1_usize;
    for _ in 0..multiplicity {
        diagonal_stride = diagonal_stride.checked_add(power).ok_or_else(|| {
            candle_core::Error::msg(format!(
                "einsum operand {operand_index} diagonal stride overflows usize"
            ))
        })?;
        power = power.checked_mul(extent).ok_or_else(|| {
            candle_core::Error::msg(format!(
                "einsum operand {operand_index} repeated-axis extent product overflows usize"
            ))
        })?;
    }
    Ok((power, diagonal_stride))
}

fn expand_axis_pattern<'a>(
    pattern: EinsumAxisPattern<'a>,
    ellipsis_rank: usize,
    implicit_operand_ellipsis: bool,
) -> Vec<ExpandedAxis<'a>> {
    let synthetic = (0..ellipsis_rank).map(ExpandedAxis::Ellipsis);
    match pattern.ellipsis_position {
        Some(position) => pattern.labels[..position]
            .iter()
            .copied()
            .map(ExpandedAxis::Named)
            .chain(synthetic)
            .chain(
                pattern.labels[position..]
                    .iter()
                    .copied()
                    .map(ExpandedAxis::Named),
            )
            .collect(),
        None if implicit_operand_ellipsis => synthetic
            .chain(pattern.labels.iter().copied().map(ExpandedAxis::Named))
            .collect(),
        None => pattern
            .labels
            .iter()
            .copied()
            .map(ExpandedAxis::Named)
            .collect(),
    }
}

fn validate_expanded_output(
    inputs: &[&[ExpandedAxis<'_>]],
    output: &[ExpandedAxis<'_>],
) -> Result<()> {
    for axis in output {
        if !inputs.iter().any(|input| input.contains(axis)) {
            candle_core::bail!(
                "invalid ellipsis einsum plan: output axis `{}` does not occur in an input",
                axis.display_name()
            )
        }
    }
    Ok(())
}

struct ExpandedBinaryPlan<'a> {
    batch: Vec<ExpandedAxis<'a>>,
    left_free: Vec<ExpandedAxis<'a>>,
    contracted: Vec<ExpandedAxis<'a>>,
    right_free: Vec<ExpandedAxis<'a>>,
    left_reductions: Vec<usize>,
    right_reductions: Vec<usize>,
    left_permutation: Vec<usize>,
    right_permutation: Vec<usize>,
    output_permutation: Vec<usize>,
}

struct ExpandedBinaryGraph<'a> {
    plan: ExpandedBinaryPlan<'a>,
    work: u128,
    output_elements: u128,
    copy_bytes: u128,
    submissions: u128,
    output_layout: NaryLayoutEstimate,
}

impl ExpandedBinaryGraph<'_> {
    fn cost(&self) -> NaryPairCost {
        NaryPairCost {
            flops: self.work,
            output_elements: self.output_elements,
            copy_bytes: self.copy_bytes,
            submissions: self.submissions,
        }
    }
}

#[derive(Clone, Copy)]
enum BinaryOperandLayout<'a> {
    Contiguous,
    Strided(&'a [usize]),
    Unsupported,
}

#[derive(Clone, Copy)]
struct BinaryGraphOperand<'axes, 'labels> {
    axes: &'axes [ExpandedAxis<'labels>],
    dims: &'axes [usize],
    layout: BinaryOperandLayout<'axes>,
}

fn classify_expanded_binary_graph<'a>(
    left: BinaryGraphOperand<'_, 'a>,
    right: BinaryGraphOperand<'_, 'a>,
    output_axes: &[ExpandedAxis<'a>],
    element_bytes: usize,
) -> Result<ExpandedBinaryGraph<'a>> {
    let BinaryGraphOperand {
        axes: left_axes,
        dims: left_dims,
        layout: left_layout,
    } = left;
    let BinaryGraphOperand {
        axes: right_axes,
        dims: right_dims,
        layout: right_layout,
    } = right;
    if left_axes.len() != left_dims.len() || right_axes.len() != right_dims.len() {
        candle_core::bail!("binary graph axes and dimensions have different ranks")
    }
    let plan = classify_expanded_binary(left_axes, right_axes, output_axes);
    let extent = |axis: ExpandedAxis<'a>| -> Result<usize> {
        let left = left_axes
            .iter()
            .position(|candidate| *candidate == axis)
            .map(|index| left_dims[index]);
        let right = right_axes
            .iter()
            .position(|candidate| *candidate == axis)
            .map(|index| right_dims[index]);
        match (left, right) {
            (Some(left), Some(right)) => resolve_extent(&axis.display_name(), left, right),
            (Some(extent), None) | (None, Some(extent)) => Ok(extent),
            (None, None) => candle_core::bail!("binary graph output axis is absent from inputs"),
        }
    };
    let product = |axes: &[ExpandedAxis<'a>]| -> Result<u128> {
        let mut value = 1_u128;
        for &axis in axes {
            let axis = extent(axis)? as u128;
            if axis == 0 {
                return Ok(0);
            }
            value = value
                .checked_mul(axis)
                .ok_or_else(|| candle_core::Error::msg("n-ary dimension product overflows u128"))?;
        }
        Ok(value)
    };
    let output_elements = product(output_axes)?;
    let left_reduction_work = if plan.left_reductions.is_empty() {
        0
    } else {
        checked_nary_product(left_dims)?
    };
    let right_reduction_work = if plan.right_reductions.is_empty() {
        0
    } else {
        checked_nary_product(right_dims)?
    };
    let reduction_submissions = u128::from(!plan.left_reductions.is_empty())
        + u128::from(!plan.right_reductions.is_empty());
    let canonical_axes = plan
        .batch
        .iter()
        .chain(&plan.left_free)
        .chain(&plan.contracted)
        .chain(&plan.right_free)
        .copied()
        .collect::<Vec<_>>();
    let core_work = if plan.contracted.is_empty() {
        output_elements
    } else {
        product(&canonical_axes)?
    };
    let mut zero_core = false;
    if !plan.contracted.is_empty() {
        for &axis in &canonical_axes {
            zero_core |= extent(axis)? == 0;
        }
    }

    let contiguous_strides = |dims: &[usize]| -> Result<Vec<usize>> {
        let mut strides = vec![0; dims.len()];
        let mut stride = 1usize;
        for (axis, &dimension) in dims.iter().enumerate().rev() {
            strides[axis] = stride;
            stride = stride.checked_mul(dimension).ok_or_else(|| {
                candle_core::Error::msg("binary graph stride estimate overflows usize")
            })?;
        }
        Ok(strides)
    };
    let materialized_bytes = |axes: &[ExpandedAxis<'a>],
                              dims: &[usize],
                              layout: BinaryOperandLayout<'_>,
                              reductions: &[usize],
                              permutation: &[usize],
                              group_lengths: &[usize]|
     -> Result<u128> {
        let mut broadcasted = false;
        let mut target_elements = 1_u128;
        let mut remaining_dims = Vec::with_capacity(axes.len() - reductions.len());
        for (index, (&axis, &dimension)) in axes.iter().zip(dims).enumerate() {
            if reductions.contains(&index) {
                continue;
            }
            let resolved = extent(axis)?;
            broadcasted |= resolved != dimension;
            if resolved == 0 {
                target_elements = 0;
            } else if target_elements != 0 {
                target_elements =
                    target_elements
                        .checked_mul(resolved as u128)
                        .ok_or_else(|| {
                            candle_core::Error::msg("binary graph copy estimate overflows u128")
                        })?;
            }
            remaining_dims.push(dimension);
        }
        let target_bytes = || {
            target_elements
                .checked_mul(element_bytes as u128)
                .ok_or_else(|| candle_core::Error::msg("binary graph copy estimate overflows u128"))
        };
        if broadcasted {
            return target_bytes();
        }
        let naturally_contiguous =
            !reductions.is_empty() || matches!(layout, BinaryOperandLayout::Contiguous);
        if naturally_contiguous && permutation.iter().copied().eq(0..permutation.len()) {
            return Ok(0);
        }
        if naturally_contiguous && group_lengths.iter().all(|&length| length <= 1) {
            return Ok(0);
        }
        let strides = if reductions.is_empty() {
            match layout {
                BinaryOperandLayout::Contiguous => contiguous_strides(dims)?,
                BinaryOperandLayout::Strided(strides) if strides.len() == dims.len() => {
                    strides.to_vec()
                }
                BinaryOperandLayout::Strided(_) => {
                    candle_core::bail!("binary graph dimensions and strides have different ranks")
                }
                BinaryOperandLayout::Unsupported => return target_bytes(),
            }
        } else {
            contiguous_strides(&remaining_dims)?
        };
        let canonical_dims = permutation
            .iter()
            .map(|&axis| remaining_dims[axis])
            .collect::<Vec<_>>();
        let canonical_strides = permutation
            .iter()
            .map(|&axis| strides[axis])
            .collect::<Vec<_>>();
        let nonempty_groups = group_lengths
            .iter()
            .copied()
            .filter(|&length| length != 0)
            .collect::<Vec<_>>();
        if nonempty_groups.is_empty()
            || crate::backend::plan_permute_compose_group_order(
                &canonical_dims,
                &canonical_strides,
                &(0..canonical_dims.len()).collect::<Vec<_>>(),
                &nonempty_groups,
            )?
            .is_some()
        {
            return Ok(0);
        }
        target_bytes()
    };
    let copy_bytes = if plan.contracted.is_empty() || zero_core {
        0
    } else {
        materialized_bytes(
            left_axes,
            left_dims,
            left_layout,
            &plan.left_reductions,
            &plan.left_permutation,
            &[
                plan.batch.len(),
                plan.left_free.len(),
                plan.contracted.len(),
            ],
        )?
        .checked_add(materialized_bytes(
            right_axes,
            right_dims,
            right_layout,
            &plan.right_reductions,
            &plan.right_permutation,
            &[
                plan.batch.len(),
                plan.contracted.len(),
                plan.right_free.len(),
            ],
        )?)
        .ok_or_else(|| candle_core::Error::msg("binary graph copy estimate overflows u128"))?
    };
    let work = left_reduction_work
        .checked_add(right_reduction_work)
        .and_then(|work| work.checked_add(if zero_core { 0 } else { core_work }))
        .ok_or_else(|| candle_core::Error::msg("binary graph work estimate overflows u128"))?;
    Ok(ExpandedBinaryGraph {
        plan,
        work,
        output_elements,
        copy_bytes,
        submissions: reduction_submissions + if zero_core { 2 } else { 1 },
        output_layout: if zero_core {
            NaryLayoutEstimate::Unsupported
        } else {
            NaryLayoutEstimate::Contiguous
        },
    })
}

fn classify_expanded_binary<'a>(
    left: &[ExpandedAxis<'a>],
    right: &[ExpandedAxis<'a>],
    output: &[ExpandedAxis<'a>],
) -> ExpandedBinaryPlan<'a> {
    let mut all = Vec::new();
    for axis in left.iter().chain(right) {
        if !all.contains(axis) {
            all.push(*axis);
        }
    }
    let batch = all
        .iter()
        .copied()
        .filter(|axis| left.contains(axis) && right.contains(axis) && output.contains(axis))
        .collect::<Vec<_>>();
    let left_free = all
        .iter()
        .copied()
        .filter(|axis| left.contains(axis) && !right.contains(axis) && output.contains(axis))
        .collect::<Vec<_>>();
    let contracted = all
        .iter()
        .copied()
        .filter(|axis| left.contains(axis) && right.contains(axis) && !output.contains(axis))
        .collect::<Vec<_>>();
    let right_free = all
        .iter()
        .copied()
        .filter(|axis| !left.contains(axis) && right.contains(axis) && output.contains(axis))
        .collect::<Vec<_>>();
    let left_reductions = left
        .iter()
        .enumerate()
        .filter_map(|(index, axis)| {
            (!right.contains(axis) && !output.contains(axis)).then_some(index)
        })
        .collect();
    let right_reductions = right
        .iter()
        .enumerate()
        .filter_map(|(index, axis)| {
            (!left.contains(axis) && !output.contains(axis)).then_some(index)
        })
        .collect();
    let left_remaining = left
        .iter()
        .copied()
        .filter(|axis| right.contains(axis) || output.contains(axis))
        .collect::<Vec<_>>();
    let right_remaining = right
        .iter()
        .copied()
        .filter(|axis| left.contains(axis) || output.contains(axis))
        .collect::<Vec<_>>();
    let left_canonical = batch
        .iter()
        .chain(&left_free)
        .chain(&contracted)
        .copied()
        .collect::<Vec<_>>();
    let right_canonical = batch
        .iter()
        .chain(&contracted)
        .chain(&right_free)
        .copied()
        .collect::<Vec<_>>();
    let canonical_output = batch
        .iter()
        .chain(&left_free)
        .chain(&right_free)
        .copied()
        .collect::<Vec<_>>();
    ExpandedBinaryPlan {
        batch,
        left_free,
        contracted,
        right_free,
        left_reductions,
        right_reductions,
        left_permutation: dynamic_permutation(&left_remaining, &left_canonical),
        right_permutation: dynamic_permutation(&right_remaining, &right_canonical),
        output_permutation: dynamic_permutation(&canonical_output, output),
    }
}

fn dynamic_permutation<T: Eq>(current: &[T], desired: &[T]) -> Vec<usize> {
    desired
        .iter()
        .map(|axis| {
            current
                .iter()
                .position(|candidate| candidate == axis)
                .expect("validated ellipsis classification")
        })
        .collect()
}

fn materialize_broadcast_if_needed(
    tensor: &Tensor,
    shape: &[usize],
    context: &'static str,
) -> Result<Tensor> {
    if tensor.dims() == shape {
        Ok(tensor.clone())
    } else {
        tensor
            .broadcast_as(shape)
            .and_then(|tensor| tensor.contiguous())
            .map_err(|error| error.context(context))
    }
}

fn pack_canonical_operand(
    tensor: &Tensor,
    packed_shape: &[usize],
    group_lengths: &[usize],
    context: &'static str,
) -> Result<Tensor> {
    if packed_shape.len() != group_lengths.len() {
        candle_core::bail!(
            "{context}: packed rank {} does not match group rank {}",
            packed_shape.len(),
            group_lengths.len()
        )
    }

    let materialized;
    let tensor = if tensor
        .dims()
        .iter()
        .zip(tensor.stride())
        .any(|(&extent, &stride)| extent > 1 && stride == 0)
    {
        materialized = tensor
            .contiguous()
            .map_err(|error| error.context(context))?;
        &materialized
    } else {
        tensor
    };

    let mut nonempty_shape = Vec::with_capacity(packed_shape.len());
    let mut nonempty_lengths = Vec::with_capacity(group_lengths.len());
    for (&extent, &length) in packed_shape.iter().zip(group_lengths) {
        if length == 0 {
            if extent != 1 {
                candle_core::bail!("{context}: an empty axis group must have extent one")
            }
        } else {
            nonempty_shape.push(extent);
            nonempty_lengths.push(length);
        }
    }

    let mut output = if nonempty_lengths.is_empty() {
        tensor.clone()
    } else {
        let identity = (0..tensor.rank()).collect::<Vec<_>>();
        execute_tensor_permute_and_compose(tensor, &identity, &nonempty_shape, &nonempty_lengths)
            .map_err(|error| error.context(context))?
    };
    for (axis, &length) in group_lengths.iter().enumerate() {
        if length == 0 {
            output = output
                .unsqueeze(axis)
                .map_err(|error| error.context(context))?;
        }
    }
    Ok(output)
}

/// Packs already-canonical operand groups through the production layout path.
#[cfg(feature = "benchmark-internals")]
#[doc(hidden)]
pub fn benchmark_pack_canonical_operand(
    tensor: &Tensor,
    packed_shape: &[usize],
    group_lengths: &[usize],
) -> Result<Tensor> {
    pack_canonical_operand(
        tensor,
        packed_shape,
        group_lengths,
        "benchmark canonical operand packing",
    )
}

fn apply_output_permutation(output: Tensor, permutation: &[usize]) -> Result<Tensor> {
    if permutation.iter().copied().eq(0..permutation.len()) {
        Ok(output)
    } else {
        output
            .permute(permutation)
            .map_err(|error| error.context("einsum binary explicit output permutation"))
    }
}

fn prepare_operand(
    operand: &Tensor,
    operand_index: usize,
    input_rank: usize,
    reduction_axes: &[usize],
    permutation: &[usize],
) -> Result<Tensor> {
    let mut reduced = vec![false; input_rank];
    for &axis in reduction_axes {
        if axis >= input_rank {
            candle_core::bail!(
                "invalid binary einsum plan: operand {operand_index} reduction axis {axis} is out of range for rank {input_rank}"
            )
        }
        if std::mem::replace(&mut reduced[axis], true) {
            candle_core::bail!(
                "invalid binary einsum plan: operand {operand_index} reduction axis {axis} occurs more than once"
            )
        }
    }
    let remaining_rank = input_rank - reduction_axes.len();
    validate_permutation(permutation, remaining_rank, "operand")?;
    let operand = if reduction_axes.is_empty() {
        operand.clone()
    } else {
        operand.sum(reduction_axes).map_err(|error| {
            error.context(format!("einsum operand {operand_index} pre-reduction"))
        })?
    };
    if permutation.iter().copied().eq(0..remaining_rank) {
        Ok(operand)
    } else {
        operand.permute(permutation).map_err(|error| {
            error.context(format!(
                "einsum operand {operand_index} canonical permutation"
            ))
        })
    }
}

fn validate_permutation(permutation: &[usize], rank: usize, context: &str) -> Result<()> {
    if permutation.len() != rank {
        candle_core::bail!(
            "invalid binary einsum plan: {context} permutation has {} axes, expected {rank}",
            permutation.len(),
        )
    }
    let mut seen = vec![false; rank];
    for &axis in permutation {
        if axis >= rank || std::mem::replace(&mut seen[axis], true) {
            candle_core::bail!(
                "invalid binary einsum plan: {context} permutation is not a permutation of 0..{rank}"
            )
        }
    }
    Ok(())
}

fn resolve_extent(label: &str, left: usize, right: usize) -> Result<usize> {
    match (left, right) {
        (left, right) if left == right => Ok(left),
        (1, right) => Ok(right),
        (left, 1) => Ok(left),
        _ => {
            candle_core::bail!("einsum label `{label}` cannot broadcast extents {left} and {right}")
        }
    }
}

fn checked_product(dimensions: &[usize], category: &str) -> Result<usize> {
    dimensions.iter().try_fold(1_usize, |product, &extent| {
        product.checked_mul(extent).ok_or_else(|| {
            candle_core::Error::msg(format!(
                "einsum binary {category} flattened extent overflows usize"
            ))
        })
    })
}

#[cfg(test)]
mod tests {
    use super::*;
    use candle_core::{DType, Device, Storage, Var};

    fn storage_address(tensor: &Tensor) -> *const Storage {
        let (storage, _) = tensor.storage_and_layout();
        std::ptr::from_ref(&*storage)
    }

    #[test]
    fn canonical_group_packing_uses_the_calibrated_cpu_rank_two_layout() -> Result<()> {
        let source = Tensor::arange(0f32, 24., &Device::Cpu)?.reshape((4, 2, 3))?;
        let canonical = source.permute((1, 2, 0))?;
        assert!(!canonical.is_contiguous());
        let historical = canonical.reshape((1, 6, 4))?;
        assert_ne!(storage_address(&historical), storage_address(&source));

        let packed =
            pack_canonical_operand(&canonical, &[1, 6, 4], &[0, 2, 1], "test canonical operand")?;
        assert_eq!(packed.dims(), [1, 6, 4]);
        assert_ne!(storage_address(&packed), storage_address(&source));
        assert!(packed.is_contiguous());
        assert_eq!(
            packed.flatten_all()?.to_vec1::<f32>()?,
            historical.flatten_all()?.to_vec1::<f32>()?
        );
        Ok(())
    }

    #[test]
    fn canonical_group_packing_preserves_broadcast_and_reduction_order() -> Result<()> {
        let left = Tensor::arange(1f32, 13., &Device::Cpu)?
            .reshape((2, 1, 2, 3))?
            .sum(0)?
            .broadcast_as((2, 2, 3))?;
        let right = Tensor::ones((2, 3, 4, 2), DType::F32, &Device::Cpu)?.sum(3)?;
        for (tensor, shape) in [(&left, [2, 2, 3]), (&right, [2, 3, 4])] {
            let historical = tensor.reshape(&shape)?;
            let packed = pack_canonical_operand(tensor, &shape, &[1, 1, 1], "test packing")?;
            assert_eq!(
                packed.flatten_all()?.to_vec1::<f32>()?,
                historical.flatten_all()?.to_vec1::<f32>()?,
                "dims={:?} strides={:?}",
                tensor.dims(),
                tensor.stride()
            );
        }
        let historical = left
            .reshape((2, 2, 3))?
            .matmul(&right.reshape((2, 3, 4))?)?;
        let packed_left = pack_canonical_operand(&left, &[2, 2, 3], &[1, 1, 1], "test left")?;
        let packed_right = pack_canonical_operand(&right, &[2, 3, 4], &[1, 1, 1], "test right")?;
        assert!(
            packed_left.is_contiguous(),
            "left strides {:?}",
            packed_left.stride()
        );
        assert!(
            packed_right.is_contiguous(),
            "right strides {:?}",
            packed_right.stride()
        );
        let packed = packed_left.matmul(&packed_right)?;
        assert_eq!(
            packed.flatten_all()?.to_vec1::<f32>()?,
            historical.flatten_all()?.to_vec1::<f32>()?
        );
        Ok(())
    }

    #[test]
    fn rejects_invalid_runtime_specs_without_panicking() -> Result<()> {
        let input = Tensor::zeros((2, 3), DType::F32, &Device::Cpu)?;

        assert!(execute_unary_einsum(&input, UnaryEinsumSpec::new(3, 2, &[0, 1, 2])).is_err());
        assert!(execute_unary_einsum(&input, UnaryEinsumSpec::new(2, 3, &[0, 1])).is_err());
        assert!(execute_unary_einsum(&input, UnaryEinsumSpec::new(2, 2, &[0])).is_err());
        assert!(execute_unary_einsum(&input, UnaryEinsumSpec::new(2, 2, &[0, 2])).is_err());
        assert!(execute_unary_einsum(&input, UnaryEinsumSpec::new(2, 2, &[0, 0])).is_err());

        Ok(())
    }

    #[test]
    fn rejects_invalid_binary_specs_and_checked_shape_overflow() -> Result<()> {
        let left = Tensor::zeros((2, 3), DType::F32, &Device::Cpu)?;
        let right = Tensor::zeros((3, 4), DType::F32, &Device::Cpu)?;
        let valid = BinaryEinsumSpec::new(
            [2, 2],
            [&[], &[]],
            [&[0, 1], &[0, 1]],
            0,
            1,
            1,
            1,
            &[],
            &["inner"],
            &[0, 1],
        );
        assert_eq!(execute_binary_einsum(&left, &right, valid)?.dims(), &[2, 4]);

        let invalid = BinaryEinsumSpec::new(
            [2, 2],
            [&[], &[]],
            [&[0, 0], &[0, 1]],
            0,
            1,
            1,
            1,
            &[],
            &["inner"],
            &[0, 1],
        );
        assert!(execute_binary_einsum(&left, &right, invalid).is_err());
        assert!(checked_product(&[usize::MAX, 2], "test").is_err());
        Ok(())
    }

    #[test]
    fn ellipsis_runtime_validates_rank_and_normalizes_right_alignment() -> Result<()> {
        let vector = Tensor::zeros(1, DType::F32, &Device::Cpu)?;
        let invalid_operands = [EinsumAxisPattern::new(&["row", "inner"], Some(0))];
        let invalid =
            EllipsisEinsumSpec::new(&invalid_operands, EinsumAxisPattern::new(&["row"], Some(0)));
        assert!(execute_unary_ellipsis_einsum(&vector, invalid).is_err());

        let left = Tensor::ones((2, 1, 2, 3), DType::F32, &Device::Cpu)?;
        let right = Tensor::ones((4, 3, 2), DType::F32, &Device::Cpu)?;
        let valid_operands = [
            EinsumAxisPattern::new(&["row", "inner"], Some(0)),
            EinsumAxisPattern::new(&["inner", "column"], Some(0)),
        ];
        let valid = EllipsisEinsumSpec::new(
            &valid_operands,
            EinsumAxisPattern::new(&["row", "column"], Some(1)),
        );
        assert_eq!(
            execute_binary_ellipsis_einsum(&left, &right, valid)?.dims(),
            &[2, 2, 4, 2]
        );
        Ok(())
    }

    #[test]
    fn diagonal_layout_arithmetic_is_checked() {
        assert!(checked_diagonal_layout(usize::MAX, 2, 0).is_err());
        assert_eq!(checked_diagonal_layout(3, 3, 0).unwrap(), (27, 13));
        assert_eq!(checked_diagonal_layout(0, 3, 0).unwrap(), (0, 1));
    }

    fn named_axes(labels: &[&'static str]) -> Vec<ExpandedAxis<'static>> {
        labels.iter().copied().map(ExpandedAxis::Named).collect()
    }

    #[test]
    fn diagonal_plan_selects_only_when_sequential_flatten_would_copy() -> Result<()> {
        assert_eq!(
            plan_repeated_axis_lowering(&[3, 3], &named_axes(&["i", "i"]), true, 0)?,
            RepeatedAxisLoweringPlan::Sequential
        );
        assert_eq!(
            plan_repeated_axis_lowering(&[2, 3, 3], &named_axes(&["batch", "i", "i"]), true, 0,)?,
            RepeatedAxisLoweringPlan::OriginalFlatGather {
                output_shape: vec![2, 3],
                offsets: vec![0, 4, 8, 9, 13, 17],
            }
        );
        assert_eq!(
            plan_repeated_axis_lowering(
                &[2, 3, 2, 3],
                &named_axes(&["i", "j", "i", "j"]),
                true,
                0,
            )?,
            RepeatedAxisLoweringPlan::OriginalFlatGather {
                output_shape: vec![2, 3],
                offsets: vec![0, 7, 14, 21, 28, 35],
            }
        );
        Ok(())
    }

    #[test]
    fn diagonal_plan_preserves_fallbacks_and_checks_zero_before_offsets() -> Result<()> {
        assert_eq!(
            plan_repeated_axis_lowering(
                &[2, 3, 2, 3],
                &named_axes(&["i", "j", "i", "j"]),
                false,
                0,
            )?,
            RepeatedAxisLoweringPlan::Sequential
        );
        assert_eq!(
            plan_repeated_axis_lowering(
                &[2, 65_536, 65_536],
                &named_axes(&["batch", "i", "i"]),
                true,
                0,
            )?,
            RepeatedAxisLoweringPlan::Sequential
        );
        assert_eq!(
            plan_repeated_axis_lowering(
                &[256, 256, 256, 256],
                &named_axes(&["i", "j", "i", "j"]),
                true,
                0,
            )?,
            RepeatedAxisLoweringPlan::Sequential,
            "u32::MAX is Candle's zero-fill index sentinel"
        );
        assert_eq!(
            plan_repeated_axis_lowering(&[2, 0, 0], &named_axes(&["batch", "i", "i"]), true, 0,)?,
            RepeatedAxisLoweringPlan::OriginalFlatGather {
                output_shape: vec![2, 0],
                offsets: vec![],
            }
        );
        Ok(())
    }

    #[test]
    fn diagonal_plan_validates_every_repeated_extent_before_arithmetic() {
        let error = plan_repeated_axis_lowering(
            &[usize::MAX, usize::MAX, 2, 3],
            &named_axes(&["i", "i", "j", "j"]),
            true,
            0,
        )
        .expect_err("the later unequal group must be rejected first");
        assert!(error.to_string().contains("repeated label `j`"));
        assert!(error.to_string().contains("unequal extents 2 and 3"));
    }

    #[test]
    fn nary_planner_avoids_a_pathological_left_to_right_intermediate() -> Result<()> {
        let operands = vec![
            PlannedOperand::new_for_test((100, 2), &["a", "b"], 0)?,
            PlannedOperand::new_for_test((2, 100), &["b", "c"], 1)?,
            PlannedOperand::new_for_test((100, 2), &["c", "d"], 2)?,
        ];
        let output = [ExpandedAxis::Named("a"), ExpandedAxis::Named("d")];
        let left_to_right = estimate_pair(&operands, 0, 1, &output)?;
        let selected = select_nary_pair(&operands, &output)?;
        assert_eq!((selected.left, selected.right), (1, 2));
        assert_eq!(left_to_right.output_elements, 10_000);
        assert_eq!(selected.output_elements, 4);
        Ok(())
    }

    #[test]
    fn nary_planner_breaks_equal_cost_ties_by_operand_order() -> Result<()> {
        let operands = vec![
            PlannedOperand::new_for_test((2, 2), &["a", "b"], 0)?,
            PlannedOperand::new_for_test((2, 2), &["b", "c"], 1)?,
            PlannedOperand::new_for_test((2, 2), &["c", "d"], 2)?,
        ];
        let output = [ExpandedAxis::Named("a"), ExpandedAxis::Named("d")];
        let selected = select_nary_pair(&operands, &output)?;
        assert_eq!((selected.left, selected.right), (0, 1));
        assert_eq!((selected.output_elements, selected.flops), (4, 8));
        Ok(())
    }

    #[test]
    fn nary_cost_estimate_overflow_is_checked() {
        assert!(checked_nary_product(&[usize::MAX; 5]).is_err());
        assert_eq!(
            checked_nary_product(&[usize::MAX, usize::MAX, 0]).unwrap(),
            0
        );
    }

    #[test]
    fn nary_pair_model_counts_local_reduction_and_core_submission() -> Result<()> {
        let state = vec![
            planner_meta(
                0,
                &[("m", 2), ("k", 3), ("discard", 5)],
                NaryLayoutEstimate::Contiguous,
            ),
            planner_meta(1, &[("k", 3), ("n", 7)], NaryLayoutEstimate::Contiguous),
        ];
        let output = [ExpandedAxis::Named("m"), ExpandedAxis::Named("n")];
        let order = named_axes(&["m", "k", "discard", "n"]);
        let (estimate, intermediate) = model_pair_details(&state, 0, 1, &output, &order)?;

        assert_eq!(estimate.submissions, 2, "one reduction plus one GEMM");
        assert_eq!(estimate.flops, 30 + 42, "reduction work plus GEMM work");
        assert_eq!(estimate.output_elements, 14);
        assert_eq!(estimate.copy_bytes, 0);
        assert_eq!(intermediate.layout, NaryLayoutEstimate::Contiguous);
        Ok(())
    }

    #[test]
    fn nary_pair_model_distinguishes_recoverable_and_copying_strides() -> Result<()> {
        let pair = |layout| {
            vec![
                planner_meta(0, &[("a", 2), ("b", 3), ("k", 5)], layout),
                planner_meta(1, &[("k", 5), ("n", 7)], NaryLayoutEstimate::Contiguous),
            ]
        };
        let output = named_axes(&["a", "b", "n"]);
        let order = named_axes(&["a", "b", "k", "n"]);

        let (recovered, _) = model_pair_details(
            &pair(NaryLayoutEstimate::Strided(vec![3, 1, 6])),
            0,
            1,
            &output,
            &order,
        )?;
        let (copied, _) = model_pair_details(
            &pair(NaryLayoutEstimate::Strided(vec![15, 1, 3])),
            0,
            1,
            &output,
            &order,
        )?;

        assert_eq!(recovered.copy_bytes, 0);
        assert_eq!(copied.copy_bytes, 2 * 3 * 5 * 4);
        Ok(())
    }

    #[test]
    fn nary_pair_model_separates_multiply_gemm_broadcast_and_zero_graphs() -> Result<()> {
        let multiply = vec![
            planner_meta(
                0,
                &[("i", 4), ("discard", 3)],
                NaryLayoutEstimate::Contiguous,
            ),
            planner_meta(1, &[("j", 5)], NaryLayoutEstimate::Contiguous),
        ];
        let (multiply, multiply_output) = model_pair_details(
            &multiply,
            0,
            1,
            &named_axes(&["i", "j"]),
            &named_axes(&["i", "discard", "j"]),
        )?;
        assert_eq!(multiply.submissions, 2);
        assert_eq!(multiply.flops, 12 + 20);
        assert_eq!(multiply.copy_bytes, 0);
        assert_eq!(multiply_output.layout, NaryLayoutEstimate::Contiguous);

        let broadcast = vec![
            planner_meta(
                0,
                &[("batch", 1), ("m", 4), ("k", 8)],
                NaryLayoutEstimate::Contiguous,
            ),
            planner_meta(
                1,
                &[("batch", 16), ("k", 8), ("n", 2)],
                NaryLayoutEstimate::Contiguous,
            ),
        ];
        let output = named_axes(&["batch", "m", "n"]);
        let order = named_axes(&["batch", "m", "k", "n"]);
        let (broadcast, broadcast_output) = model_pair_details(&broadcast, 0, 1, &output, &order)?;
        assert_eq!(broadcast.submissions, 1);
        assert_eq!(broadcast.copy_bytes, 16 * 4 * 8 * 4);
        assert_eq!(broadcast_output.layout, NaryLayoutEstimate::Contiguous);

        let zero = vec![
            planner_meta(0, &[("m", 4), ("k", 0)], NaryLayoutEstimate::Contiguous),
            planner_meta(1, &[("k", 0), ("n", 2)], NaryLayoutEstimate::Contiguous),
        ];
        let (zero, zero_output) = model_pair_details(
            &zero,
            0,
            1,
            &named_axes(&["m", "n"]),
            &named_axes(&["m", "k", "n"]),
        )?;
        assert_eq!(zero.submissions, 2, "empty cat plus one zero reduction");
        assert_eq!(zero.flops, 0);
        assert_eq!(zero.copy_bytes, 0);
        assert_eq!(zero_output.layout, NaryLayoutEstimate::Unsupported);
        Ok(())
    }

    fn planner_meta(
        ordinal: usize,
        axes: &[(&'static str, usize)],
        layout: NaryLayoutEstimate,
    ) -> NaryPlannerMetadata<'static> {
        NaryPlannerMetadata::new_for_test(ordinal, axes, layout)
    }

    fn matrix_chain_metadata(
        dimensions: [usize; 5],
        batch: Option<usize>,
    ) -> Vec<NaryPlannerMetadata<'static>> {
        let [a, b, c, d, e] = dimensions;
        let operand = |ordinal, axes: [(&'static str, usize); 2]| {
            let mut metadata = batch
                .map(|extent| vec![("batch", if ordinal == 0 { 1 } else { extent })])
                .unwrap_or_default();
            metadata.extend(axes);
            planner_meta(ordinal, &metadata, NaryLayoutEstimate::Contiguous)
        };
        vec![
            operand(0, [("a", a), ("b", b)]),
            operand(1, [("b", b), ("c", c)]),
            operand(2, [("c", c), ("d", d)]),
            operand(3, [("d", d), ("e", e)]),
        ]
    }

    #[test]
    fn layout_aware_selection_freezes_counterexamples_and_every_boundary() {
        let balanced = matrix_chain_metadata([128, 8, 1, 8, 128], None);
        let selected = select_layout_aware_plan_for_test(&balanced, &["a", "e"], DType::F32, true);
        assert!(matches!(
            selected,
            NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration)
        ));

        let broadcast = matrix_chain_metadata([32, 32, 15, 5, 10], Some(32));
        assert!(matches!(
            select_layout_aware_plan_for_test(&broadcast, &["batch", "a", "e"], DType::F32, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration)
        ));

        let linear = matrix_chain_metadata([30, 35, 15, 5, 10], None);
        assert!(matches!(
            select_layout_aware_plan_for_test(&linear, &["a", "e"], DType::F32, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration)
        ));
        let just_below = (0..3)
            .map(|ordinal| planner_meta(ordinal, &[("k", 49_999)], NaryLayoutEstimate::Contiguous))
            .collect::<Vec<_>>();
        assert!(matches!(
            select_layout_aware_plan_for_test(&just_below, &[], DType::F32, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration)
        ));
        let at_threshold = (0..3)
            .map(|ordinal| planner_meta(ordinal, &[("k", 50_000)], NaryLayoutEstimate::Contiguous))
            .collect::<Vec<_>>();
        assert!(matches!(
            select_layout_aware_plan_for_test(&at_threshold, &[], DType::F32, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration)
        ));
        assert!(matches!(
            select_layout_aware_plan_for_test(&balanced, &["a", "e"], DType::F64, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::DType)
        ));
        assert!(matches!(
            select_layout_aware_plan_for_test(&balanced, &["a", "e"], DType::F32, false),
            NaryPlannerDecision::Greedy(NaryGreedyReason::Backend)
        ));
        let mut unsupported = balanced.clone();
        unsupported[0] = planner_meta(0, &[("a", 128), ("b", 8)], NaryLayoutEstimate::Unsupported);
        assert!(matches!(
            select_layout_aware_plan_for_test(&unsupported, &["a", "e"], DType::F32, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::UnsupportedLayout)
        ));
        let five = (0..5)
            .map(|ordinal| planner_meta(ordinal, &[("i", 128)], NaryLayoutEstimate::Contiguous))
            .collect::<Vec<_>>();
        assert!(matches!(
            select_layout_aware_plan_for_test(&five, &["i"], DType::F32, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::Arity)
        ));
    }

    #[test]
    fn exact_search_is_structurally_bounded_zero_first_checked_and_fully_stable() {
        let equal = (0..4)
            .map(|ordinal| planner_meta(ordinal, &[("i", 128)], NaryLayoutEstimate::Contiguous))
            .collect::<Vec<_>>();
        let first = plan_layout_exact_for_test(&equal, &["i"]).unwrap();
        let second = plan_layout_exact_for_test(&equal, &["i"]).unwrap();
        assert_eq!(first, second);
        assert_eq!(
            first
                .steps
                .iter()
                .map(|step| step.members)
                .collect::<Vec<_>>(),
            [(1, 2), (3, 4), (7, 8)]
        );

        let five = (0..5)
            .map(|ordinal| planner_meta(ordinal, &[("i", 128)], NaryLayoutEstimate::Contiguous))
            .collect::<Vec<_>>();
        assert!(plan_layout_exact_for_test(&five, &["i"]).is_err());

        let late_zero = vec![
            planner_meta(
                0,
                &[("huge_a", usize::MAX), ("huge_b", usize::MAX)],
                NaryLayoutEstimate::Contiguous,
            ),
            planner_meta(
                1,
                &[("huge_c", usize::MAX), ("zero", 0)],
                NaryLayoutEstimate::Contiguous,
            ),
            planner_meta(2, &[], NaryLayoutEstimate::Contiguous),
        ];
        let decision = select_layout_aware_plan_for_test(&late_zero, &[], DType::F32, true);
        assert!(matches!(
            decision,
            NaryPlannerDecision::Greedy(NaryGreedyReason::BelowFlopThreshold)
        ));

        let overflow = vec![
            planner_meta(
                0,
                &[("a", usize::MAX), ("b", usize::MAX)],
                NaryLayoutEstimate::Contiguous,
            ),
            planner_meta(
                1,
                &[("b", usize::MAX), ("c", usize::MAX)],
                NaryLayoutEstimate::Contiguous,
            ),
            planner_meta(2, &[("c", 1)], NaryLayoutEstimate::Contiguous),
        ];
        assert!(matches!(
            select_layout_aware_plan_for_test(&overflow, &["a"], DType::F32, true),
            NaryPlannerDecision::Greedy(NaryGreedyReason::Calibration)
        ));
    }

    fn nary_spec<'a>(
        operands: &'a [EinsumAxisPattern<'a>],
        output: EinsumAxisPattern<'a>,
    ) -> EllipsisEinsumSpec<'a> {
        EllipsisEinsumSpec::new(operands, output)
    }

    fn assert_mixed_close(left: &Tensor, right: &Tensor) -> Result<()> {
        assert_eq!(left.dims(), right.dims());
        let left = left.flatten_all()?.to_vec1::<f32>()?;
        let right = right.flatten_all()?.to_vec1::<f32>()?;
        for (&left, &right) in left.iter().zip(&right) {
            assert!((left - right).abs() <= 0.002 * right.abs().max(1.));
        }
        Ok(())
    }

    #[test]
    fn broadcast_selected_execution_matches_greedy_forward_and_every_gradient() -> Result<()> {
        let device = Device::Cpu;
        let patterns = [
            EinsumAxisPattern::new(&["batch", "a", "b"], None),
            EinsumAxisPattern::new(&["batch", "b", "c"], None),
            EinsumAxisPattern::new(&["batch", "c", "d"], None),
            EinsumAxisPattern::new(&["batch", "d", "e"], None),
        ];
        let output = EinsumAxisPattern::new(&["batch", "a", "e"], None);
        let shapes = [[1, 32, 32], [32, 32, 15], [32, 15, 5], [32, 5, 10]];
        let values = shapes
            .iter()
            .enumerate()
            .map(|(ordinal, shape)| {
                let elements = shape.iter().product::<usize>();
                let values = (0..elements)
                    .map(|index| ((index + ordinal * 7) % 23) as f32 / 23.)
                    .collect::<Vec<_>>();
                Tensor::from_vec(values, shape.as_slice(), &device)
            })
            .collect::<Result<Vec<_>>>()?;
        let selected_vars = values
            .iter()
            .map(Var::from_tensor)
            .collect::<Result<Vec<_>>>()?;
        let greedy_vars = values
            .iter()
            .map(Var::from_tensor)
            .collect::<Result<Vec<_>>>()?;
        let selected_refs = selected_vars.iter().map(Var::as_tensor).collect::<Vec<_>>();
        let greedy_refs = greedy_vars.iter().map(Var::as_tensor).collect::<Vec<_>>();
        let (selected, trace) = execute_nary_einsum_for_test(
            &selected_refs,
            nary_spec(&patterns, output),
            NaryExecutionStrategy::Selected,
        )?;
        let (greedy, greedy_trace) = execute_nary_einsum_for_test(
            &greedy_refs,
            nary_spec(&patterns, output),
            NaryExecutionStrategy::StreamingGreedy,
        )?;
        assert_mixed_close(&selected, &greedy)?;
        assert!(!trace.used_exact);
        assert_eq!(trace.member_sequence, greedy_trace.member_sequence);

        let selected_gradients = selected.sum_all()?.backward()?;
        let greedy_gradients = greedy.sum_all()?.backward()?;
        for (selected, greedy) in selected_vars.iter().zip(&greedy_vars) {
            assert_mixed_close(
                selected_gradients.get(selected.as_tensor()).unwrap(),
                greedy_gradients.get(greedy.as_tensor()).unwrap(),
            )?;
        }
        Ok(())
    }

    #[test]
    fn selected_execution_matches_frozen_greedy_forward_gradients_and_layout_trace() -> Result<()> {
        clear_nary_plan_cache_for_test();
        let device = Device::Cpu;
        let patterns = [
            EinsumAxisPattern::new(&["a", "b"], None),
            EinsumAxisPattern::new(&["b", "c"], None),
            EinsumAxisPattern::new(&["c", "d"], None),
            EinsumAxisPattern::new(&["d", "e"], None),
        ];
        let output = EinsumAxisPattern::new(&["a", "e"], None);
        let values = [
            Tensor::arange(0f32, (128 * 8) as f32, &device)?.reshape((128, 8))?,
            Tensor::arange(0f32, 8., &device)?.reshape((8, 1))?,
            Tensor::arange(0f32, 8., &device)?.reshape((1, 8))?,
            Tensor::arange(0f32, (8 * 128) as f32, &device)?.reshape((8, 128))?,
        ];
        let selected_vars = values
            .iter()
            .map(Var::from_tensor)
            .collect::<Result<Vec<_>>>()?;
        let greedy_vars = values
            .iter()
            .map(Var::from_tensor)
            .collect::<Result<Vec<_>>>()?;
        let selected_refs = selected_vars
            .iter()
            .map(|var| var.as_tensor())
            .collect::<Vec<_>>();
        let greedy_refs = greedy_vars
            .iter()
            .map(|var| var.as_tensor())
            .collect::<Vec<_>>();
        let (selected, trace) = execute_nary_einsum_for_test(
            &selected_refs,
            nary_spec(&patterns, output),
            NaryExecutionStrategy::Selected,
        )?;
        let (_, cached_trace) = execute_nary_einsum_for_test(
            &selected_refs,
            nary_spec(&patterns, output),
            NaryExecutionStrategy::Selected,
        )?;
        let (greedy, greedy_trace) = execute_nary_einsum_for_test(
            &greedy_refs,
            nary_spec(&patterns, output),
            NaryExecutionStrategy::StreamingGreedy,
        )?;
        assert_mixed_close(&selected, &greedy)?;
        assert!(!trace.used_exact);
        assert!(!trace.used_cached_greedy);
        assert!(cached_trace.used_cached_greedy);
        assert_eq!(cached_trace.member_sequence, trace.member_sequence);
        assert!(!greedy_trace.used_exact);
        assert_eq!(trace.member_sequence, greedy_trace.member_sequence);
        assert_eq!(trace.final_permutations, 1);
        assert!(trace.intermediates.iter().all(|step| step.canonical));
        assert!(
            trace
                .intermediates
                .iter()
                .all(|step| step.estimated == step.execution_graph)
        );
        assert!(
            trace
                .intermediates
                .iter()
                .all(|step| { step.output_layout == NaryLayoutEstimate::Contiguous })
        );

        let selected_gradients = selected.sum_all()?.backward()?;
        let greedy_gradients = greedy.sum_all()?.backward()?;
        for (selected, greedy) in selected_vars.iter().zip(&greedy_vars) {
            assert_mixed_close(
                selected_gradients.get(selected.as_tensor()).unwrap(),
                greedy_gradients.get(greedy.as_tensor()).unwrap(),
            )?;
        }
        Ok(())
    }
}