From c88c035a5ee926fc5aadb348c91815df46733911 Mon Sep 17 00:00:00 2001 From: Michael Tremer Date: Thu, 6 Feb 2025 16:46:23 +0000 Subject: [PATCH] database: Log less Signed-off-by: Michael Tremer --- src/buildservice/database.py | 58 +++++++++++++++++------------------- 1 file changed, 28 insertions(+), 30 deletions(-) diff --git a/src/buildservice/database.py b/src/buildservice/database.py index c380b2b9..8238d25f 100644 --- a/src/buildservice/database.py +++ b/src/buildservice/database.py @@ -34,36 +34,34 @@ from . import base # Setup logging log = logging.getLogger("pbs.database") -@sqlalchemy.event.listens_for(sqlalchemy.Engine, "before_cursor_execute") -def before_cursor_execute(conn, cursor, statement, parameters, context, executemany): - now = time.time() - - # Create a queue to store start times - try: - q = conn.info["query_start_time"] - except KeyError: - q = conn.info["query_start_time"] = queue.LifoQueue() - - # Push the start time of the query - q.put(now) - - # Log the statement - log.debug("Start Query: %s %r", statement, parameters) - - -@sqlalchemy.event.listens_for(sqlalchemy.Engine, "after_cursor_execute") -def after_cursor_execute(conn, cursor, statement, parameters, context, executemany): - time_end = time.time() - - # Fetch the latest start time - time_start = conn.info["query_start_time"].get() - - # Compute the total time - t = time_end - time_start - - # Log the total runtime - log.debug("Query completed in %.02fms", t * 1000) - +#@sqlalchemy.event.listens_for(sqlalchemy.Engine, "before_cursor_execute") +#def before_cursor_execute(conn, cursor, statement, parameters, context, executemany): +# now = time.time() +# +# # Create a queue to store start times +# try: +# q = conn.info["query_start_time"] +# except KeyError: +# q = conn.info["query_start_time"] = queue.LifoQueue() +# +# # Push the start time of the query +# q.put(now) +# +# # Log the statement +# log.debug("Start Query: %s %r", statement, parameters) +# +#@sqlalchemy.event.listens_for(sqlalchemy.Engine, "after_cursor_execute") +#def after_cursor_execute(conn, cursor, statement, parameters, context, executemany): +# time_end = time.time() +# +# # Fetch the latest start time +# time_start = conn.info["query_start_time"].get() +# +# # Compute the total time +# t = time_end - time_start +# +# # Log the total runtime +# log.debug("Query completed in %.02fms", t * 1000) class Base(sqlalchemy.ext.asyncio.AsyncAttrs, sqlalchemy.orm.DeclarativeBase): """ -- 2.47.2