summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorH. Shay <hillerys@element.io>2023-06-05 19:21:59 -0700
committerH. Shay <hillerys@element.io>2023-06-05 19:21:59 -0700
commitb4cc31d9065c90d1f721fcc59f7bf9de1e92d8a1 (patch)
tree7ea6ce8012ece39080aa022c5f6bf2714d50846e /synapse/storage
parentnewsfragment (diff)
downloadsynapse-b4cc31d9065c90d1f721fcc59f7bf9de1e92d8a1.tar.xz
lint
Diffstat (limited to 'synapse/storage')
-rw-r--r--synapse/storage/databases/state/bg_updates.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/synapse/storage/databases/state/bg_updates.py b/synapse/storage/databases/state/bg_updates.py
index ab4c180451..b07a00624b 100644
--- a/synapse/storage/databases/state/bg_updates.py
+++ b/synapse/storage/databases/state/bg_updates.py
@@ -534,7 +534,7 @@ class StateBackgroundUpdateStore(StateGroupBackgroundUpdateStore):
                 check if the column event_stream_ordering already exists
                 """
                 check_sql = f"""
-                    SELECT column_name FROM information_schema.columns 
+                    SELECT column_name FROM information_schema.columns
                     WHERE table_name = '{table}' and column_name = 'event_stream_ordering';
                     """
                 txn.execute(check_sql)
@@ -641,7 +641,9 @@ class StateBackgroundUpdateStore(StateGroupBackgroundUpdateStore):
                         """
                     )
 
-            await self.db_pool.runInteraction("add_sqlite_triggers", add_sqlite_triggers)
+            await self.db_pool.runInteraction(
+                "add_sqlite_triggers", add_sqlite_triggers
+            )
         elif isinstance(self.database_engine, PostgresEngine):
 
             def add_pg_triggers(txn: LoggingTransaction) -> None:
@@ -675,9 +677,7 @@ class StateBackgroundUpdateStore(StateGroupBackgroundUpdateStore):
                         """
                     )
 
-            await self.db_pool.runInteraction(
-                "add_postgres_triggers", add_pg_triggers
-            )
+            await self.db_pool.runInteraction("add_postgres_triggers", add_pg_triggers)
         else:
             raise NotImplementedError("Unknown database engine")