aip_sdk.iter_ingest_drops

aip_sdk.iter_ingest_drops(version_id: str, *, page_size: int = 500, client: APIClient | None = None) -> Iterator[TraceDropRecord]

Iterate every record dropped while landing traces into a dataset version.

Pages are fetched lazily as the iterator is consumed, so a version with many drops is never materialised in full. A failed ingestion can drop as many records as it read, which is why this is the default way to read them.

Parameters

• version_id str: Dataset version ID the ingestion run landed into.
• page_size int: Records to fetch per request (1 to MAX_DROPS_PER_PAGE). Affects only request granularity, not the records yielded.
• client APIClient | None: Optional API client.

Yields

• TraceDropRecord: Each drop record for the version, oldest first.

Raises

• InvalidArgumentError: If page_size is out of range.
• AuthError: If credentials are missing or invalid.
• NotFoundError: If the dataset version does not exist, or belongs to a workspace the caller is not a member of.
• ResponseParseError: If the platform's response does not match this SDK version.