mirror of
https://github.com/GSA/notifications-api.git
synced 2026-08-24 00:06:16 -04:00
fix format
This commit is contained in:
@@ -389,15 +389,32 @@ def setup_sqlalchemy_events(app):
|
|||||||
|
|
||||||
@event.listens_for(db.engine, "connect")
|
@event.listens_for(db.engine, "connect")
|
||||||
def connect(dbapi_connection, connection_record):
|
def connect(dbapi_connection, connection_record):
|
||||||
|
if dbapi_connection is None or connection_record is None:
|
||||||
|
current_app.logger.warning(
|
||||||
|
f"Something wrong with sqalalchemy \
|
||||||
|
dbapi_connection {dbapi_connection} connection_record {connection_record}"
|
||||||
|
)
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@event.listens_for(db.engine, "close")
|
@event.listens_for(db.engine, "close")
|
||||||
def close(dbapi_connection, connection_record):
|
def close(dbapi_connection, connection_record):
|
||||||
|
|
||||||
|
if dbapi_connection is None or connection_record is None:
|
||||||
|
current_app.logger.warning(
|
||||||
|
f"Something wrong with sqalalchemy \
|
||||||
|
dbapi_connection {dbapi_connection} connection_record {connection_record}"
|
||||||
|
)
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@event.listens_for(db.engine, "checkout")
|
@event.listens_for(db.engine, "checkout")
|
||||||
def checkout(dbapi_connection, connection_record, connection_proxy):
|
def checkout(dbapi_connection, connection_record, connection_proxy):
|
||||||
|
|
||||||
|
if dbapi_connection is None or connection_proxy is None:
|
||||||
|
current_app.logger.warning(
|
||||||
|
f"Something wrong with sqalalchemy \
|
||||||
|
dbapi_connection {dbapi_connection} connection_record {connection_proxy}"
|
||||||
|
)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
# this will overwrite any previous checkout_at timestamp
|
# this will overwrite any previous checkout_at timestamp
|
||||||
connection_record.info["checkout_at"] = time.monotonic()
|
connection_record.info["checkout_at"] = time.monotonic()
|
||||||
@@ -439,6 +456,12 @@ def setup_sqlalchemy_events(app):
|
|||||||
|
|
||||||
@event.listens_for(db.engine, "checkin")
|
@event.listens_for(db.engine, "checkin")
|
||||||
def checkin(dbapi_connection, connection_record):
|
def checkin(dbapi_connection, connection_record):
|
||||||
|
|
||||||
|
if dbapi_connection is None or connection_record is None:
|
||||||
|
current_app.logger.warning(
|
||||||
|
f"Something wrong with sqalalchemy \
|
||||||
|
dbapi_connection {dbapi_connection} connection_record {connection_record}"
|
||||||
|
)
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user