Skip to main content

aip_sdk.delete_rows

aip_sdk.delete_rows(dataset_id: str, row_ids: list[str], current_snapshot_id: str | int | None = None, client: APIClient | None = None) -> list[str]

Delete rows by row ID.

Parameters

  • dataset_id str: Dataset ID.
  • row_ids list[str]: List of row IDs to delete.
  • 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

  • list[str]: List of deleted row IDs.

Raises

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