Merge remote-tracking branch 'origin/master' into task/modify-lakefs-…

…python-docs-7120

# Conflicts:
#	clients/python-wrapper/lakefs/repository.py

api/swagger.yml

@@ -585,14 +585,17 @@ components:
 
     TagCreation:
       type: object
+      description: Make tag ID point at this REF.
       required:
         - id
         - ref
       properties:
         id:
           type: string
+          description: ID of tag to create
         ref:
           type: string
+          description: the commit to tag
 
     TaskInfo:
       type: object

clients/python-wrapper/lakefs/branch.py

@@ -54,8 +54,9 @@ def handle_conflict(e: LakeFSException):
             if isinstance(e, ConflictException) and exist_ok:
                 return None
             return e
-
-        branch_creation = lakefs_sdk.BranchCreation(name=self._id, source=str(source_reference_id))
+        if isinstance(source_reference_id, Reference):
+            source_reference_id = source_reference_id.id
+        branch_creation = lakefs_sdk.BranchCreation(name=self._id, source=source_reference_id)
         with api_exception_handler(handle_conflict):
             self._client.sdk_client.branches_api.create_branch(self._repo_id, branch_creation)
         return self
@@ -192,10 +193,12 @@ def delete_objects(self, object_paths: str | StoredObject | Iterable[str | Store
         :raise NotAuthorizedException: if user is not authorized to perform this operation
         :raise ServerException: for any other errors
         """
-        if isinstance(object_paths, (str, StoredObject)):
-            object_paths = [str(object_paths)]
+        if isinstance(object_paths, str):
+            object_paths = [object_paths]
+        elif isinstance(object_paths, StoredObject):
+            object_paths = [object_paths.path]
         elif isinstance(object_paths, Iterable):
-            object_paths = {str(o) for o in object_paths}
+            object_paths = [o.path if isinstance(o, StoredObject) else o for o in object_paths]
         with api_exception_handler():
             return self._client.sdk_client.objects_api.delete_objects(
                 self._repo_id,

clients/python-wrapper/lakefs/models.py

@@ -35,6 +35,9 @@ class Change(LenientNamedTuple):
     path_type: Literal["common_prefix", "object"]
     size_bytes: Optional[int]
 
+    def __repr__(self):
+        return f'Change(type="{self.type}", path="{self.path}", path_type="{self.path_type}")'
+
 
 class ImportStatus(LenientNamedTuple):
     """
@@ -90,13 +93,19 @@ class ObjectInfo(LenientNamedTuple):
     metadata: Optional[dict[str, str]] = None
     content_type: Optional[str] = None
 
+    def __repr__(self):
+        return f'ObjectInfo(path="{self.path}")'
+
 
 class CommonPrefix(LenientNamedTuple):
     """
     Represents a common prefix in lakeFS
     """
     path: str
 
+    def __repr__(self):
+        return f'CommonPrefix(path="{self.path}")'
+
 
 class RepositoryProperties(LenientNamedTuple):
     """

clients/python-wrapper/lakefs/namedtuple.py

@@ -27,6 +27,12 @@ def __init__(self, **kwargs):
         self.__initialized = True
         super().__init__()
 
+    def __repr__(self):
+        class_name = self.__class__.__name__
+        if hasattr(self, 'id'):
+            return f'{class_name}(id="{self.id}")'
+        return f'{class_name}()'
+
     def __setattr__(self, name, value):
         if self.__initialized:
             raise AttributeError("can't set attribute")