Răsfoiți Sursa

Postgres db_wait fix

Andrew Morgan 4 ani în urmă
părinte
comite
db2652cc5e
1 a modificat fișierele cu 2 adăugiri și 0 ștergeri
  1. 2 0
      synapse/storage/engines/postgres.py

+ 2 - 0
synapse/storage/engines/postgres.py

@@ -14,6 +14,7 @@
 # limitations under the License.
 
 import logging
+import psycopg2.extras
 
 from ._base import BaseDatabaseEngine, IncorrectDatabaseSetup
 
@@ -24,6 +25,7 @@ class PostgresEngine(BaseDatabaseEngine):
     def __init__(self, database_module, database_config):
         super().__init__(database_module, database_config)
         self.module.extensions.register_type(self.module.extensions.UNICODE)
+        self.module.extensions.set_wait_callback(psycopg2.extras.wait_select)
 
         # Disables passing `bytes` to txn.execute, c.f. #6186. If you do
         # actually want to use bytes than wrap it in `bytearray`.