Skip to main content

aip_sdk.update_rows

aip_sdk.update_rows(dataset_id: str, updates: dict[str, dict[str, Any]], current_snapshot_id: str | int | None = None, client: APIClient | None = None) -> dict[str, dict[str, Any]]

Update existing rows by row ID.

Parameters

  • dataset_id str: Dataset ID.
  • updates dict[str, dict[str, Any]]: Mapping of {row_id: {column: new_value, ...}}.
  • current_snapshot_id str | int | None: Optional Iceberg snapshot ID for conflict detection. Accepts either str or int; serialised as string to the API.
  • client APIClient | None: Optional API client.

Returns

  • dict[str, dict[str, Any]]: Updated rows keyed by row ID.

Raises

  • APIError: On HTTP error, including 409 when current_snapshot_id mismatches.