zcollection.collection.Collection.validate_partitions#

Collection.validate_partitions(filters=None, fix=False)[source]#

Validates partitions in the collection by checking if they exist and are readable. If fix is True, invalid partitions will be removed from the collection.

Parameters:
  • filters (str | Callable[[Dict[str, int]], bool] | None) – The predicate used to filter the partitions to validate. By default, all partitions are validated.

  • fix (bool) – Whether to fix invalid partitions by removing them from the collection.

Returns:

A list of invalid partitions.

Return type:

list[str]