Function execute_cow_update

crates/integrations/datafusion/src/update.rs:167–176

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

(
    ctx: &SQLContext,
    update: &Update,
    table: &Table,
)

/// Execute UPDATE on an append-only table with retry on delete conflict.
async fn execute_cow_update(
    ctx: &SQLContext,
    update: &Update,
    table: &Table,
) -> DFResult<DataFrame> {
    retry_on_conflict("CoW UPDATE", is_delete_conflict, || {
        execute_cow_update_once(ctx, update, table)
    })
    .await
}

/// Single attempt of CoW UPDATE execution.
async fn execute_cow_update_once(