style: format by ruff

Author: emptybutton

src/tgdb/application/horizon/commit_transaction.py

@@ -35,9 +35,7 @@ class CommitTransaction:
     channel: Channel
     commit_buffer: Buffer[Commit | PreparedCommit]
 
-    async def __call__(
-        self, xid: XID, operators: Sequence[Operator]
-    ) -> None:
+    async def __call__(self, xid: XID, operators: Sequence[Operator]) -> None:
         """
         :raises tgdb.application.relation.ports.relations.NoRelationError:
         :raises tgdb.entities.horizon.horizon.NoTransactionError:

src/tgdb/application/horizon/output_commits.py

@@ -37,7 +37,8 @@ async def __call__(self) -> None:
                     try:
                         horizon.complete_commit(time, commit.xid)
                     except (
-                        NoTransactionError, TransactionNotCommittingError
+                        NoTransactionError,
+                        TransactionNotCommittingError,
                     ) as error:
                         await self.channel.publish(commit.xid, error)
                     else:

src/tgdb/entities/horizon/horizon.py

@@ -158,7 +158,8 @@ def commit_transaction(
         self.move_to_future(time)
 
         transaction = self._transaction(
-            xid, SerializableTransactionState.active,
+            xid,
+            SerializableTransactionState.active,
             else_=TransactionCommittingError(),
         )
 
@@ -243,7 +244,7 @@ def _is_transaction_autorollbackable(
     ) -> bool:
         return (
             not isinstance(transaction, SerializableTransaction)
-            or transaction.state is not SerializableTransactionState.prepared
+            or transaction.state() is not SerializableTransactionState.prepared
         )
 
     def _oldest_transaction(self) -> Transaction | None:

src/tgdb/entities/horizon/transaction.py

@@ -251,16 +251,13 @@ def include(self, effect: ConflictableTransactionScalarEffect) -> None:
 
         self._space[effect.tid] = effect
 
-    def rollback(self) -> None:
-        ...
+    def rollback(self) -> None: ...
 
     def commit(self) -> Commit:
         return Commit(self._xid, frozenset(self._space.values()))
 
     @classmethod
-    def start(
-        cls, xid: XID, time: LogicTime
-    ) -> "ReadUncommitedTransaction":
+    def start(cls, xid: XID, time: LogicTime) -> "ReadUncommitedTransaction":
         return ReadUncommitedTransaction(
             _xid=xid,
             _start_time=time,

src/tgdb/entities/relation/domain.py

@@ -61,10 +61,5 @@ class UuidDomain(_TypeDomain):
 
 
 type Domain = (
-    IntDomain
-    | StrDomain
-    | BoolDomain
-    | DatetimeDomain
-    | UuidDomain
-    | SetDomain
+    IntDomain | StrDomain | BoolDomain | DatetimeDomain | UuidDomain | SetDomain
 )

src/tgdb/entities/relation/tuple.py

@@ -39,8 +39,7 @@ def __getitem__(self, index: int, /) -> Scalar: ...
     @overload
     def __getitem__(
         self, sclice: "slice[Any, Any, Any]", /
-    ) -> Sequence[Scalar]:
-        ...
+    ) -> Sequence[Scalar]: ...
 
     def __getitem__(
         self, key: "int | slice[Any, Any, Any]", /

src/tgdb/entities/relation/tuple_effect.py

@@ -37,7 +37,9 @@ def tid(self) -> TID:
 class MutatedTuple:
     tuple: Tuple
 
-    def __and__(self, effect: "TupleEffect") -> "MutatedTuple | DeletedTuple | MigratedTuple":
+    def __and__(
+        self, effect: "TupleEffect"
+    ) -> "MutatedTuple | DeletedTuple | MigratedTuple":
         match effect:
             case JustViewedTuple():
                 return self
@@ -55,7 +57,9 @@ def tid(self) -> TID:
 class MigratedTuple:
     tuple: Tuple
 
-    def __and__(self, effect: "TupleEffect") -> "MutatedTuple | MigratedTuple | DeletedTuple":
+    def __and__(
+        self, effect: "TupleEffect"
+    ) -> "MutatedTuple | MigratedTuple | DeletedTuple":
         match effect:
             case JustViewedTuple():
                 return self
@@ -94,11 +98,7 @@ class InvalidRelationTupleError(Exception):
 
 
 type TupleEffect = (
-    NewTuple
-    | JustViewedTuple
-    | MutatedTuple
-    | MigratedTuple
-    | DeletedTuple
+    NewTuple | JustViewedTuple | MutatedTuple | MigratedTuple | DeletedTuple
 )
 
 

src/tgdb/infrastructure/adapters/buffer.py

@@ -81,7 +81,7 @@ async def add(self, commit: Commit | PreparedCommit, /) -> None:
         await self._buffer.add(commit)
 
     async def __aiter__(
-        self
+        self,
     ) -> AsyncIterator[Sequence[Commit | PreparedCommit]]:
         async for commits in self._buffer:
             encoded_commits = pickle.dumps(list(commits))

src/tgdb/infrastructure/adapters/tuples.py

@@ -32,20 +32,21 @@
 class InMemoryTuples(Tuples):
     _db: InMemoryDb[Tuple]
 
-    async def assert_can_accept_tuples(self, relation: Relation) -> None:
-        ...
+    async def assert_can_accept_tuples(self, relation: Relation) -> None: ...
 
     async def tuples_with_attribute(
         self,
         relation_number: Number,
         attribute_number: Number,
         attribute_scalar: Scalar,
     ) -> Sequence[Tuple]:
-        return self._db.select_many(lambda it: (
-            it.relation_schema_id.relation_number == relation_number
-            and len(it) >= int(attribute_number)
-            and it[int(attribute_number)] == attribute_scalar
-        ))
+        return self._db.select_many(
+            lambda it: (
+                it.relation_schema_id.relation_number == relation_number
+                and len(it) >= int(attribute_number)
+                and it[int(attribute_number)] == attribute_scalar
+            )
+        )
 
     async def map(self, effects: Sequence[TransactionEffect]) -> None:
         await gather(*map(self._map_one, effects))
@@ -75,7 +76,8 @@ async def _map_one(self, effect: TransactionEffect) -> None:
                     self._db.remove(prevous_tuple)
                     self._db.insert(next_tuple)
 
-                case _: ...
+                case _:
+                    ...
 
     async def _map_one_idempotently(self, effect: TransactionEffect) -> None:
         for tuple_effect in effect:
@@ -91,7 +93,8 @@ async def _map_one_idempotently(self, effect: TransactionEffect) -> None:
                     self._db.remove(prevous_tuple)
                     self._db.insert(next_tuple)
 
-                case _: ...
+                case _:
+                    ...
 
 
 @dataclass(frozen=True)
@@ -120,20 +123,24 @@ async def tuples_with_attribute(
     async def map(
         self, transaction_effects: Sequence[TransactionEffect]
     ) -> None:
-        await gather(*(
-            self._map_scalar_effect(tuple_effect, idempotently=False)
-            for transaction_effect in transaction_effects
-            for tuple_effect in transaction_effect
-        ))
+        await gather(
+            *(
+                self._map_scalar_effect(tuple_effect, idempotently=False)
+                for transaction_effect in transaction_effects
+                for tuple_effect in transaction_effect
+            )
+        )
 
     async def map_idempotently(
         self, transaction_effects: Sequence[TransactionEffect]
     ) -> None:
-        await gather(*(
-            self._map_scalar_effect(tuple_effect, idempotently=True)
-            for transaction_effect in transaction_effects
-            for tuple_effect in transaction_effect
-        ))
+        await gather(
+            *(
+                self._map_scalar_effect(tuple_effect, idempotently=True)
+                for transaction_effect in transaction_effects
+                for tuple_effect in transaction_effect
+            )
+        )
 
     async def _map_scalar_effect(
         self, scalar_effect: TransactionScalarEffect, idempotently: bool

src/tgdb/infrastructure/async_map.py

@@ -5,9 +5,7 @@
 
 @dataclass(frozen=True, unsafe_hash=False)
 class AsyncMap[KeyT, ValueT]:
-    _map: dict[KeyT, Future[ValueT]] = field(
-        init=False, default_factory=dict
-    )
+    _map: dict[KeyT, Future[ValueT]] = field(init=False, default_factory=dict)
 
     def __iter__(self) -> Iterator[KeyT]:
         return iter(self._map)