discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

feat: give little timeout for resource stab
All checks were successful
Deploy on push / deploy (push) Successful in 51s
Details

Browse Source
This commit is contained in:
Stepan Vladovskiy 2025-03-24 21:42:51 -03:00
parent 077cb46482
commit 6e284640c0
1 changed files with 26 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
main.py
View File

@ -64,15 +64,12 @@ async def lifespan(_app):
) )
print("[lifespan] Basic initialization complete") print("[lifespan] Basic initialization complete")
# After basic initialization is complete, fetch shouts and initialize search # Add a delay before starting the intensive search indexing
print("[lifespan] Starting search indexing process") print("[lifespan] Waiting for system stabilization before search indexing...")
from services.db import fetch_all_shouts # Import your database access function await asyncio.sleep(10) # 10-second delay to let the system stabilize
all_shouts = await fetch_all_shouts()
print(f"[lifespan] Fetched {len(all_shouts) if all_shouts else 0} shouts for indexing") # Start search indexing as a background task with lower priority
asyncio.create_task(initialize_search_index_background())
print("[lifespan] Initializing search index...")
await initialize_search_index(all_shouts)
print("[lifespan] Search index initialization complete")
yield yield
finally: finally:
@ -80,6 +77,26 @@ async def lifespan(_app):
tasks = [redis.disconnect(), ViewedStorage.stop(), revalidation_manager.stop()] tasks = [redis.disconnect(), ViewedStorage.stop(), revalidation_manager.stop()]
await asyncio.gather(*tasks, return_exceptions=True) await asyncio.gather(*tasks, return_exceptions=True)
print("[lifespan] Shutdown complete") print("[lifespan] Shutdown complete")
# Initialize search index in the background
async def initialize_search_index_background():
"""Run search indexing as a background task with low priority"""
try:
print("[search] Starting background search indexing process")
from services.db import fetch_all_shouts
# Get total count first (optional)
all_shouts = await fetch_all_shouts()
total_count = len(all_shouts) if all_shouts else 0
print(f"[search] Fetched {total_count} shouts for background indexing")
# Start the indexing process with the fetched shouts
print("[search] Beginning background search index initialization...")
await initialize_search_index(all_shouts)
print("[search] Background search index initialization complete")
except Exception as e:
print(f"[search] Error in background search indexing: {str(e)}")
# Создаем экземпляр GraphQL # Создаем экземпляр GraphQL
graphql_app = GraphQL(schema, debug=True) graphql_app = GraphQL(schema, debug=True)