style: format by ruff

Author: emptybutton

src/tgdb/application/horizon/commit_transaction.py

@@ -58,7 +58,8 @@ async def __call__(self, xid: XID, operators: Sequence[Operator]) -> None:
             raise notification from notification
 
     async def _effect(
-        self, operator: Operator,
+        self,
+        operator: Operator,
     ) -> NewTuple | MutatedTuple | DeletedTuple | Claim:
         """
         :raises tgdb.application.relation.ports.relations.NoRelationError:

src/tgdb/application/relation/create_relation.py

@@ -13,7 +13,9 @@ class CreateRelation:
     tuples: Tuples
 
     async def __call__(
-        self, relation_number: Number, relation_schema: Schema,
+        self,
+        relation_number: Number,
+        relation_schema: Schema,
     ) -> None:
         """
         :raises tgdb.application.relation.ports.relations.OversizedRelationSchemaError:

src/tgdb/application/relation/ports/relation_views.py

@@ -9,5 +9,6 @@ async def view_of_all_relations(self) -> ViewOfAllRelationsT: ...
 
     @abstractmethod
     async def view_of_one_relation(
-        self, relation_number: Number,
+        self,
+        relation_number: Number,
     ) -> ViewOfOneRelationT: ...

src/tgdb/application/relation/ports/tuples.py

@@ -30,7 +30,9 @@ async def map(self, effects: Sequence[TransactionEffect], /) -> None: ...
 
     @abstractmethod
     async def map_idempotently(
-        self, effects: Sequence[TransactionEffect], /,
+        self,
+        effects: Sequence[TransactionEffect],
+        /,
     ) -> None: ...
 
     @abstractmethod

src/tgdb/application/relation/view_tuples.py

@@ -34,7 +34,9 @@ async def __call__(
         """
 
         tuples = await self.tuples.tuples_with_attribute(
-            relation_number, attribute_number, attribute_scalar,
+            relation_number,
+            attribute_number,
+            attribute_scalar,
         )
         versioned_tuples = map(versioned_tuple, tuples)
         relation = await self.relartions.relation(relation_number)

src/tgdb/entities/horizon/horizon.py

@@ -59,7 +59,8 @@ class Horizon:
     _max_transaction_age: LogicTime
     _serializable_transaction_map: OrderedDict[XID, SerializableTransaction]
     _read_uncommited_transaction_map: OrderedDict[
-        XID, ReadUncommitedTransaction,
+        XID,
+        ReadUncommitedTransaction,
     ]
 
     def __post_init__(self) -> None:
@@ -238,7 +239,8 @@ def _limit_len(self) -> None:
             ]
 
     def _is_transaction_autorollbackable(
-        self, transaction: Transaction,
+        self,
+        transaction: Transaction,
     ) -> bool:
         return (
             not isinstance(transaction, SerializableTransaction)
@@ -286,7 +288,8 @@ def _serializable_transaction(
         return transaction
 
     def _non_serializable_read_transaction(
-        self, xid: XID,
+        self,
+        xid: XID,
     ) -> ReadUncommitedTransaction:
         """
         :raises tgdb.entities.horizon.horizon.NoTransactionError:
@@ -320,7 +323,8 @@ def _transaction_maps(self) -> Iterable[Mapping[XID, Transaction]]:
         yield self._read_uncommited_transaction_map
 
     def _transaction_map[TransactionT: Transaction](
-        self, transaction: TransactionT,
+        self,
+        transaction: TransactionT,
     ) -> OrderedDict[XID, TransactionT]:
         match transaction:
             case ReadUncommitedTransaction():
@@ -330,7 +334,9 @@ def _transaction_map[TransactionT: Transaction](
 
 
 def horizon(
-    time: LogicTime, max_len: int, max_transaction_age: LogicTime,
+    time: LogicTime,
+    max_len: int,
+    max_transaction_age: LogicTime,
 ) -> Horizon:
     """
     :raises tgdb.entities.horizon.horizon.HorizonAlwaysWithoutTransactionsError:

src/tgdb/entities/horizon/transaction.py

@@ -142,25 +142,29 @@ def commit(self) -> Commit:
         return Commit(self._xid, self._effect())
 
     def track_concurrent_transaction(
-        self, transaction: "SerializableTransaction",
+        self,
+        transaction: "SerializableTransaction",
     ) -> None:
         self._concurrent_transactions.add(transaction)
 
         if transaction.state() is SerializableTransactionState.prepared:
             self._transactions_with_possible_conflict.add(transaction)
 
     def track_started_transaction(
-        self, started_transaction: "SerializableTransaction",
+        self,
+        started_transaction: "SerializableTransaction",
     ) -> None:
         self._concurrent_transactions.add(started_transaction)
 
     def track_prepared_transaction(
-        self, prepared_transaction: "SerializableTransaction",
+        self,
+        prepared_transaction: "SerializableTransaction",
     ) -> None:
         self._transactions_with_possible_conflict.add(prepared_transaction)
 
     def track_rollbacked_prepared_transaction(
-        self, rollbacked_prepared_transaction: "SerializableTransaction",
+        self,
+        rollbacked_prepared_transaction: "SerializableTransaction",
     ) -> None:
         if self._state is SerializableTransactionState.active:
             self._transactions_with_possible_conflict.remove(
@@ -171,7 +175,8 @@ def track_rollbacked_prepared_transaction(
             )
 
     def track_rollbacked_active_transaction(
-        self, rollbacked_active_transaction: "SerializableTransaction",
+        self,
+        rollbacked_active_transaction: "SerializableTransaction",
     ) -> None:
         if self._state is SerializableTransactionState.active:
             self._concurrent_transactions.remove(rollbacked_active_transaction)
@@ -289,7 +294,9 @@ def start_transaction(
     match isolation:
         case IsolationLevel.serializable:
             return SerializableTransaction.start(
-                xid, time, serializable_transactions,
+                xid,
+                time,
+                serializable_transactions,
             )
 
         case IsolationLevel.read_uncommited:

src/tgdb/entities/relation/relation.py

@@ -76,7 +76,8 @@ def last_version_schema_id(self) -> RelationSchemaID:
         return RelationSchemaID(self._number, self.last_version().number)
 
     def recent_versions(
-        self, current_version_number: Number,
+        self,
+        current_version_number: Number,
     ) -> Sequence[DerivativeRelationVersion]:
         if current_version_number < self._initial_version.number:
             return tuple()
@@ -111,7 +112,8 @@ def migrate(
     def remove_old_versions(self, count: int) -> None:
         count_to_remove_intermediate_versions = count - 1
         count_to_remove_intermediate_versions = min(
-            count_to_remove_intermediate_versions, len(self) - 1,
+            count_to_remove_intermediate_versions,
+            len(self) - 1,
         )
         del self._intermediate_versions[:count_to_remove_intermediate_versions]
 

src/tgdb/entities/relation/tuple.py

@@ -38,11 +38,15 @@ def __getitem__(self, index: int, /) -> Scalar: ...
 
     @overload
     def __getitem__(
-        self, sclice: "slice[Any, Any, Any]", /,
+        self,
+        sclice: "slice[Any, Any, Any]",
+        /,
     ) -> Sequence[Scalar]: ...
 
     def __getitem__(
-        self, key: "int | slice[Any, Any, Any]", /,
+        self,
+        key: "int | slice[Any, Any, Any]",
+        /,
     ) -> Scalar | Sequence[Scalar]:
         return self.scalars[key]
 

src/tgdb/entities/relation/tuple_effect.py

@@ -38,7 +38,8 @@ class MutatedTuple:
     tuple: Tuple
 
     def __and__(
-        self, effect: "TupleEffect",
+        self,
+        effect: "TupleEffect",
     ) -> "MutatedTuple | DeletedTuple | MigratedTuple":
         match effect:
             case JustViewedTuple():
@@ -58,7 +59,8 @@ class MigratedTuple:
     tuple: Tuple
 
     def __and__(
-        self, effect: "TupleEffect",
+        self,
+        effect: "TupleEffect",
     ) -> "MutatedTuple | MigratedTuple | DeletedTuple":
         match effect:
             case JustViewedTuple():
@@ -111,7 +113,9 @@ def relation_tuple(tuple_: Tuple, relation: Relation) -> Tuple:
 
     if not tuple_.matches(relation_last_version.schema):
         raise InvalidRelationTupleError(
-            tuple_.tid, tuple_.scalars, relation.number(),
+            tuple_.tid,
+            tuple_.scalars,
+            relation.number(),
         )
 
     return tuple_
@@ -128,7 +132,8 @@ def constructed_relation_tuple(
 
     relation_last_version = relation.last_version()
     relation_last_version_id = RelationSchemaID(
-        relation.number(), relation_last_version.number,
+        relation.number(),
+        relation_last_version.number,
     )
 
     tuple_ = Tuple(tid, relation_last_version_id, scalars)
@@ -177,7 +182,9 @@ def viewed_tuple(tuple_: VersionedTuple, relation: Relation) -> ViewedTuple:
 
     if not last_version.matches(relation.last_version().schema):
         raise InvalidRelationTupleError(
-            last_version.tid, last_version.scalars, relation.number(),
+            last_version.tid,
+            last_version.scalars,
+            relation.number(),
         )
 
     if old_versions: