Function execute_cow_delete

crates/integrations/datafusion/src/delete.rs:77–87

Execute DELETE on an append-only table with retry on delete conflict.

(
    ctx: &SQLContext,
    delete: &Delete,
    table: &Table,
    table_ref: &str,
)

/// Execute DELETE on an append-only table with retry on delete conflict.
async fn execute_cow_delete(
    ctx: &SQLContext,
    delete: &Delete,
    table: &Table,
    table_ref: &str,
) -> DFResult<DataFrame> {
    retry_on_conflict("CoW DELETE", is_delete_conflict, || {
        execute_cow_delete_once(ctx, delete, table, table_ref)
    })
    .await
}

/// Single attempt of CoW DELETE execution.
async fn execute_cow_delete_once(