Function mz_catalog::durable::upgrade::run_versioned_upgrade

source ยท 
async fn run_versioned_upgrade<V1: IntoStateUpdateKindJson, V2: IntoStateUpdateKindJson>(
    unopened_catalog_state: &mut PersistHandle<StateUpdateKindJson, UnopenedCatalogStateInner>,
    current_version: u64,
    commit_ts: Timestamp,
    migration_logic: impl FnOnce(Vec<V1>) -> Vec<MigrationAction<V1, V2>>,
) -> Result<(u64, Timestamp), CatalogError>
Expand description

Runs migration_logic on the contents of the current catalog assuming a current version of current_version.

Returns the new version and upper.