Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 6 additions & 3 deletions pyiceberg/catalog/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,8 @@ def delete_files(io: FileIO, files_to_delete: set[str], file_type: str) -> None:
try:
io.delete(file)
except OSError as exc:
logger.warning(msg=f"Failed to delete {file_type} file {file}", exc_info=exc)
logger.warning(msg=f"Failed to delete {file_type} file {file}")
logger.debug(f"Error deleting {file_type} file {file}", exc_info=exc)


def delete_data_files(io: FileIO, manifests_to_delete: list[ManifestFile]) -> None:
Expand All @@ -306,7 +307,8 @@ def delete_data_files(io: FileIO, manifests_to_delete: list[ManifestFile]) -> No
try:
io.delete(path)
except OSError as exc:
logger.warning(msg=f"Failed to delete data file {path}", exc_info=exc)
logger.warning(msg=f"Failed to delete data file {path}")
logger.debug(f"Error deleting data file {path}", exc_info=exc)
deleted_files[path] = True


Expand All @@ -320,7 +322,8 @@ def _import_catalog(name: str, catalog_impl: str, properties: Properties) -> Cat
class_ = getattr(module, class_name)
return class_(name, **properties)
except ModuleNotFoundError as exc:
logger.warning(f"Could not initialize Catalog: {catalog_impl}", exc_info=exc)
logger.warning(f"Could not initialize Catalog: {catalog_impl}")
logger.debug(f"Failed to load {catalog_impl}", exc_info=exc)
return None


Expand Down
3 changes: 2 additions & 1 deletion pyiceberg/io/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,8 @@ def _import_file_io(io_impl: str, properties: Properties) -> FileIO | None:
class_ = getattr(module, class_name)
return class_(properties)
except ModuleNotFoundError as exc:
logger.warning(f"Could not initialize FileIO: {io_impl}", exc_info=exc)
logger.warning(f"Could not initialize FileIO: {io_impl}")
logger.debug(f"Failed to load {io_impl}", exc_info=exc)
return None


Expand Down
3 changes: 2 additions & 1 deletion pyiceberg/table/locations.py
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,8 @@ def _import_location_provider(
class_ = getattr(module, class_name)
return class_(table_location, table_properties)
except ModuleNotFoundError as exc:
logger.warning(f"Could not initialize LocationProvider: {location_provider_impl}", exc_info=exc)
logger.warning(f"Could not initialize LocationProvider: {location_provider_impl}")
logger.debug(f"Failed to load {location_provider_impl}", exc_info=exc)
return None


Expand Down
Loading