diff --git a/resolvers/author.py b/resolvers/author.py index 5ab23e4e..8e67796a 100644 --- a/resolvers/author.py +++ b/resolvers/author.py @@ -71,6 +71,7 @@ async def get_author(_, _info, slug='', author_id=None): q = select(Author).where(Author.id == author_id) [author] = await get_authors_with_stat_cached(q) if author: + logger.debug(f'queried author from db {cache_key} -> {cache}') author_dict = author.dict() else: logger.warn('author was not cached!') diff --git a/resolvers/stat.py b/resolvers/stat.py index 62dc22cd..07c6bc3c 100644 --- a/resolvers/stat.py +++ b/resolvers/stat.py @@ -197,6 +197,7 @@ def get_with_stat(q): async def get_authors_with_stat_cached(q): + logger.debug(q) try: records = [] with local_session() as session: diff --git a/services/db.py b/services/db.py index 9548cd7f..0ee579d4 100644 --- a/services/db.py +++ b/services/db.py @@ -93,6 +93,7 @@ def before_cursor_execute(conn, cursor, statement, parameters, context, executem conn.query_start_time = time.time() conn.last_statement = '' + @event.listens_for(Engine, 'after_cursor_execute') def after_cursor_execute(conn, cursor, statement, parameters, context, executemany): compiled_statement = context.compiled.string