We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6fde1fe commit 9265902Copy full SHA for 9265902
1 file changed
eventsourcing_sqlalchemy/recorders.py
@@ -99,6 +99,7 @@ def _lock_table(self, session: Session) -> None:
99
if self.schema_name is not None:
100
events_table_name = f"{self.schema_name}.{events_table_name}"
101
if self.datastore.engine.dialect.name == "postgresql":
102
+ # Todo: "SET LOCAL lock_timeout = '{x}s'" like in eventsourcing.postgres?
103
session.execute(text(f"LOCK TABLE {events_table_name} IN EXCLUSIVE MODE"))
104
elif self.datastore.engine.dialect.name == "mssql":
105
pass
0 commit comments