diff options
author | H. Shay <hillerys@element.io> | 2023-06-05 19:21:59 -0700 |
---|---|---|
committer | H. Shay <hillerys@element.io> | 2023-06-05 19:21:59 -0700 |
commit | b4cc31d9065c90d1f721fcc59f7bf9de1e92d8a1 (patch) | |
tree | 7ea6ce8012ece39080aa022c5f6bf2714d50846e /synapse/storage | |
parent | newsfragment (diff) | |
download | synapse-b4cc31d9065c90d1f721fcc59f7bf9de1e92d8a1.tar.xz |
lint
Diffstat (limited to 'synapse/storage')
-rw-r--r-- | synapse/storage/databases/state/bg_updates.py | 10 |
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") |