matrix-org · reivilibre · Apr 13, 2023 · Apr 13, 2023 · Apr 13, 2023 · MadLittleMods
@@ -0,0 +1 @@
+Improve DB performance of clearing out old data from `stream_ordering_to_exterm`.
@@ -1708,7 +1708,7 @@ def _delete_old_forward_extrem_cache_txn(txn: LoggingTransaction) -> None:
                 WHERE stream_ordering < ?
             """
             txn.execute(
-                sql, (self.stream_ordering_month_ago)  # type: ignore[attr-defined]
+                sql, (self.stream_ordering_month_ago,)  # type: ignore[attr-defined]
 def execute(self, sql: str, *args: Any) -> None: 
     self._do_execute(self.txn.execute, sql, *args) 
 def _do_execute( 
     self, 
     func: Callable[Concatenate[str, P], R], 
     sql: str, 
     *args: P.args, 
     **kwargs: P.kwargs, 
 ) -> R: 
 _Parameters = Union[Sequence[Any], Mapping[str, Any]] 
 class Cursor(Protocol): 
     def execute(self, sql: str, parameters: _Parameters = ...) -> Any: 
         ... 
 def execute(self, sql: str, *args: Any) -> None: 
     self._do_execute(self.txn.execute, sql, *args) 
 def _do_execute( 
     self, 
     func: Callable[Concatenate[str, P], R], 
     sql: str, 
     *args: P.args, 
     **kwargs: P.kwargs, 
 ) -> R: 
 _Parameters = Union[Sequence[Any], Mapping[str, Any]] 
  
  
 class Cursor(Protocol): 
     def execute(self, sql: str, parameters: _Parameters = ...) -> Any: 
         ... 
             )
 
         await self.db_pool.runInteraction(