From 385057ffcd7edfb2abc7056a31378f07a14da612 Mon Sep 17 00:00:00 2001 From: Stepan Vladovskiy Date: Fri, 21 Mar 2025 13:45:50 -0300 Subject: [PATCH] debug: with logs in indexing procedure --- main.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index 44c727af..9d57ac20 100644 --- a/main.py +++ b/main.py @@ -51,6 +51,7 @@ async def check_search_service(): # await initialize_search_index(all_shouts) async def lifespan(_app): try: + print("[lifespan] Starting application initialization") create_all_tables() await asyncio.gather( redis.connect(), @@ -61,18 +62,24 @@ async def lifespan(_app): start(), revalidation_manager.start(), ) + print("[lifespan] Basic initialization complete") # After basic initialization is complete, fetch shouts and initialize search + print("[lifespan] Starting search indexing process") from services.db import fetch_all_shouts # Import your database access function all_shouts = await fetch_all_shouts() + print(f"[lifespan] Fetched {len(all_shouts) if all_shouts else 0} shouts for indexing") + + print("[lifespan] Initializing search index...") await initialize_search_index(all_shouts) + print("[lifespan] Search index initialization complete") yield finally: + print("[lifespan] Shutting down application services") tasks = [redis.disconnect(), ViewedStorage.stop(), revalidation_manager.stop()] await asyncio.gather(*tasks, return_exceptions=True) - - + print("[lifespan] Shutdown complete") # Создаем экземпляр GraphQL graphql_app = GraphQL(schema, debug=True)