Module commit_retry 

Shared iceberg commit-with-retry primitive used by both the V1/V2 sink committer and the V3 sink coordinator worker. Wraps the standard pattern of “reload the table, build an action against the freshly-loaded snapshot, commit, retry on transient errors only”.

Enums

CommitError

Distinguishes retriable from non-retriable errors inside run_with_retry.

Functions

reload_table

Reload the iceberg table from the catalog and assert that its current schema_id and default_partition_spec_id still match the values the caller computed against. Schema or partition evolution mid-commit is surfaced as a non-retriable error by the call sites.

run_with_retry

Run a commit-action against the given iceberg table with retry.