Replace Black by Ruff formatter (#127)

* Replace black by Ruff Formatter

* update ruff version

* fix format

* Update ruff format and add preserve as a quote style

Author: hussein-awala

.pre-commit-config.yaml

@@ -29,15 +29,12 @@ repos:
       - id: check-ast
   - repo: https://github.com/astral-sh/ruff-pre-commit
     # Ruff version (Used for linting)
-    rev: v0.1.0
+    rev: v0.1.8
     hooks:
       - id: ruff
-        args: [ --fix, --exit-non-zero-on-fix ]
-  - repo: https://github.com/ambv/black
-    rev: 23.10.0
-    hooks:
-      - id: black
-        args: [--skip-string-normalization]
+        args: [ --fix, --exit-non-zero-on-fix, --preview ]
+      - id: ruff-format
+        args: [ --preview ]
   - repo: https://github.com/pre-commit/mirrors-mypy
     rev: v1.6.1
     hooks:

pyiceberg/avro/codecs/__init__.py

@@ -23,6 +23,7 @@
 so don't confuse it with the Python's "codecs", which is a package mainly for
 converting character sets (https://docs.python.org/3/library/codecs.html).
 """
+
 from __future__ import annotations
 
 from typing import Dict, Optional, Type

pyiceberg/avro/codecs/codec.py

@@ -24,10 +24,8 @@ class Codec(ABC):
 
     @staticmethod
     @abstractmethod
-    def compress(data: bytes) -> tuple[bytes, int]:
-        ...
+    def compress(data: bytes) -> tuple[bytes, int]: ...
 
     @staticmethod
     @abstractmethod
-    def decompress(data: bytes) -> bytes:
-        ...
+    def decompress(data: bytes) -> bytes: ...

pyiceberg/avro/file.py

@@ -16,6 +16,7 @@
 # under the License.
 # pylint: disable=W0621
 """Avro reader for reading Avro files."""
+
 from __future__ import annotations
 
 import io

pyiceberg/avro/reader.py

@@ -23,6 +23,7 @@
 The reader tree can be changed in such a way that the
 read schema is different, while respecting the read schema.
 """
+
 from __future__ import annotations
 
 from abc import abstractmethod
@@ -85,12 +86,10 @@ def _skip_map_array(decoder: BinaryDecoder, skip_entry: Callable[[], None]) -> N
 
 class Reader(Singleton):
     @abstractmethod
-    def read(self, decoder: BinaryDecoder) -> Any:
-        ...
+    def read(self, decoder: BinaryDecoder) -> Any: ...
 
     @abstractmethod
-    def skip(self, decoder: BinaryDecoder) -> None:
-        ...
+    def skip(self, decoder: BinaryDecoder) -> None: ...
 
     def __repr__(self) -> str:
         """Return the string representation of the Reader class."""

pyiceberg/avro/resolver.py

@@ -232,9 +232,7 @@ def resolve_reader(
     Raises:
         NotImplementedError: If attempting to resolve an unrecognized object type.
     """
-    return visit_with_partner(
-        file_schema, read_schema, ReadSchemaResolver(read_types, read_enums), SchemaPartnerAccessor()
-    )  # type: ignore
+    return visit_with_partner(file_schema, read_schema, ReadSchemaResolver(read_types, read_enums), SchemaPartnerAccessor())  # type: ignore
 
 
 class EnumReader(Reader):

pyiceberg/avro/writer.py

@@ -20,6 +20,7 @@
 Constructing a writer tree from the schema makes it easy
 to decouple the writing implementation from the schema.
 """
+
 from __future__ import annotations
 
 from abc import abstractmethod
@@ -43,8 +44,7 @@
 @dataclass(frozen=True)
 class Writer(Singleton):
     @abstractmethod
-    def write(self, encoder: BinaryEncoder, val: Any) -> Any:
-        ...
+    def write(self, encoder: BinaryEncoder, val: Any) -> Any: ...
 
     def __repr__(self) -> str:
         """Return string representation of this object."""

pyiceberg/cli/output.py

@@ -40,48 +40,37 @@ class Output(ABC):
     """Output interface for exporting."""
 
     @abstractmethod
-    def exception(self, ex: Exception) -> None:
-        ...
+    def exception(self, ex: Exception) -> None: ...
 
     @abstractmethod
-    def identifiers(self, identifiers: List[Identifier]) -> None:
-        ...
+    def identifiers(self, identifiers: List[Identifier]) -> None: ...
 
     @abstractmethod
-    def describe_table(self, table: Table) -> None:
-        ...
+    def describe_table(self, table: Table) -> None: ...
 
     @abstractmethod
-    def files(self, table: Table, history: bool) -> None:
-        ...
+    def files(self, table: Table, history: bool) -> None: ...
 
     @abstractmethod
-    def describe_properties(self, properties: Properties) -> None:
-        ...
+    def describe_properties(self, properties: Properties) -> None: ...
 
     @abstractmethod
-    def text(self, response: str) -> None:
-        ...
+    def text(self, response: str) -> None: ...
 
     @abstractmethod
-    def schema(self, schema: Schema) -> None:
-        ...
+    def schema(self, schema: Schema) -> None: ...
 
     @abstractmethod
-    def spec(self, spec: PartitionSpec) -> None:
-        ...
+    def spec(self, spec: PartitionSpec) -> None: ...
 
     @abstractmethod
-    def uuid(self, uuid: Optional[UUID]) -> None:
-        ...
+    def uuid(self, uuid: Optional[UUID]) -> None: ...
 
     @abstractmethod
-    def version(self, version: str) -> None:
-        ...
+    def version(self, version: str) -> None: ...
 
     @abstractmethod
-    def describe_refs(self, refs: List[Tuple[str, SnapshotRefType, Dict[str, str]]]) -> None:
-        ...
+    def describe_refs(self, refs: List[Tuple[str, SnapshotRefType, Dict[str, str]]]) -> None: ...
 
 
 class ConsoleOutput(Output):
@@ -252,10 +241,8 @@ def version(self, version: str) -> None:
         self._out({"version": version})
 
     def describe_refs(self, refs: List[Tuple[str, SnapshotRefType, Dict[str, str]]]) -> None:
-        self._out(
-            [
-                {"name": name, "type": type, detail_key: detail_val}
-                for name, type, detail in refs
-                for detail_key, detail_val in detail.items()
-            ]
-        )
+        self._out([
+            {"name": name, "type": type, detail_key: detail_val}
+            for name, type, detail in refs
+            for detail_key, detail_val in detail.items()
+        ])

pyiceberg/conversions.py

@@ -27,6 +27,7 @@
     implementation, a concrete function is registered for each generic conversion function. For PrimitiveType
     implementations that share the same conversion logic, registrations can be stacked.
 """
+
 import uuid
 from datetime import date, datetime, time
 from decimal import Decimal

pyiceberg/expressions/__init__.py

@@ -80,13 +80,11 @@ class Unbound(Generic[B], ABC):
     """Represents an unbound value expression."""
 
     @abstractmethod
-    def bind(self, schema: Schema, case_sensitive: bool = True) -> B:
-        ...
+    def bind(self, schema: Schema, case_sensitive: bool = True) -> B: ...
 
     @property
     @abstractmethod
-    def as_bound(self) -> Type[Bound]:
-        ...
+    def as_bound(self) -> Type[Bound]: ...
 
 
 class BoundTerm(Term[L], Bound, ABC):
@@ -142,8 +140,7 @@ class UnboundTerm(Term[Any], Unbound[BoundTerm[L]], ABC):
     """Represents an unbound term."""
 
     @abstractmethod
-    def bind(self, schema: Schema, case_sensitive: bool = True) -> BoundTerm[L]:
-        ...
+    def bind(self, schema: Schema, case_sensitive: bool = True) -> BoundTerm[L]: ...
 
 
 class Reference(UnboundTerm[Any]):
@@ -352,8 +349,7 @@ def __eq__(self, other: Any) -> bool:
 
     @property
     @abstractmethod
-    def as_unbound(self) -> Type[UnboundPredicate[Any]]:
-        ...
+    def as_unbound(self) -> Type[UnboundPredicate[Any]]: ...
 
 
 class UnboundPredicate(Generic[L], Unbound[BooleanExpression], BooleanExpression, ABC):
@@ -367,13 +363,11 @@ def __eq__(self, other: Any) -> bool:
         return self.term == other.term if isinstance(other, self.__class__) else False
 
     @abstractmethod
-    def bind(self, schema: Schema, case_sensitive: bool = True) -> BooleanExpression:
-        ...
+    def bind(self, schema: Schema, case_sensitive: bool = True) -> BooleanExpression: ...
 
     @property
     @abstractmethod
-    def as_bound(self) -> Type[BoundPredicate[L]]:
-        ...
+    def as_bound(self) -> Type[BoundPredicate[L]]: ...
 
 
 class UnaryPredicate(UnboundPredicate[Any], ABC):
@@ -387,8 +381,7 @@ def __repr__(self) -> str:
 
     @property
     @abstractmethod
-    def as_bound(self) -> Type[BoundUnaryPredicate[Any]]:
-        ...
+    def as_bound(self) -> Type[BoundUnaryPredicate[Any]]: ...
 
 
 class BoundUnaryPredicate(BoundPredicate[L], ABC):
@@ -398,8 +391,7 @@ def __repr__(self) -> str:
 
     @property
     @abstractmethod
-    def as_unbound(self) -> Type[UnaryPredicate]:
-        ...
+    def as_unbound(self) -> Type[UnaryPredicate]: ...
 
     def __getnewargs__(self) -> Tuple[BoundTerm[L]]:
         """Pickle the BoundUnaryPredicate class."""
@@ -575,8 +567,7 @@ def __getnewargs__(self) -> Tuple[BoundTerm[L], Set[Literal[L]]]:
 
     @property
     @abstractmethod
-    def as_unbound(self) -> Type[SetPredicate[L]]:
-        ...
+    def as_unbound(self) -> Type[SetPredicate[L]]: ...
 
 
 class BoundIn(BoundSetPredicate[L]):
@@ -705,8 +696,7 @@ def __repr__(self) -> str:
 
     @property
     @abstractmethod
-    def as_bound(self) -> Type[BoundLiteralPredicate[L]]:
-        ...
+    def as_bound(self) -> Type[BoundLiteralPredicate[L]]: ...
 
 
 class BoundLiteralPredicate(BoundPredicate[L], ABC):
@@ -729,8 +719,7 @@ def __repr__(self) -> str:
 
     @property
     @abstractmethod
-    def as_unbound(self) -> Type[LiteralPredicate[L]]:
-        ...
+    def as_unbound(self) -> Type[LiteralPredicate[L]]: ...
 
 
 class BoundEqualTo(BoundLiteralPredicate[L]):