g0ldyy/comet
1
0
Fork 0
mirror of https://github.com/g0ldyy/comet.git synced 2026-01-12 01:16:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: enhance ReplicaAwareDatabase methods for clarity and functionality

Browse Source 
- Reformatted the constructor for improved readability.
- Added 'force_primary' parameter to 'execute' and 'execute_many' methods to control query execution behavior.
- Improved formatting in '_next_replica' method for better code clarity.
This commit is contained in:
g0ldyy
2025-12-10 18:10:17 +01:00
parent 5a7e70ee67
commit d404736b3c
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
comet/core/db_router.py
+8 -4
View File
@@ -11,7 +11,9 @@ from comet.core.logger import logger
class ReplicaAwareDatabase:
"""Routes read queries to replicas while keeping writes on the primary."""
def __init__(self, primary: Database, replicas: Optional[Sequence[Database]] = None):
def __init__(
self, primary: Database, replicas: Optional[Sequence[Database]] = None
):
self._primary = primary
self._configured_replicas = list(replicas or [])
self._active_replicas: List[Database] = []
@@ -67,10 +69,10 @@ class ReplicaAwareDatabase:
primary_transaction = self._primary.transaction(*args, **kwargs)
return _ReplicaAwareTransaction(self, primary_transaction)
async def execute(self, query, values=None):
async def execute(self, query, values=None, *, force_primary: bool = False):
return await self._primary.execute(query, values)
async def execute_many(self, query, values):
async def execute_many(self, query, values, *, force_primary: bool = False):
return await self._primary.execute_many(query, values)
async def fetch_all(self, query, values=None, *, force_primary: bool = False):
@@ -97,7 +99,9 @@ class ReplicaAwareDatabase:
return False
def _next_replica(self) -> Database:
replica = self._active_replicas[self._replica_index % len(self._active_replicas)]
replica = self._active_replicas[
self._replica_index % len(self._active_replicas)
]
self._replica_index = (self._replica_index + 1) % len(self._active_replicas)
return replica