Compare commits
2 Commits
80b909d801
...
feat/sv-se
Author | SHA1 | Date | |
---|---|---|---|
![]() |
e1d1096674 | ||
![]() |
82870a4e47 |
@@ -35,7 +35,7 @@ jobs:
|
||||
ssh_private_key: ${{ secrets.SSH_PRIVATE_KEY }}
|
||||
|
||||
- name: Push to dokku for staging branch
|
||||
if: github.ref == 'refs/heads/feat/sv-search-v4'
|
||||
if: github.ref == 'refs/heads/staging'
|
||||
uses: dokku/github-action@master
|
||||
with:
|
||||
branch: 'dev'
|
||||
|
16
main.py
16
main.py
@@ -42,6 +42,15 @@ async def check_search_service():
|
||||
else:
|
||||
print(f"[INFO] Search service is available: {info}")
|
||||
|
||||
# Helper to run precache with timeout and catch errors
|
||||
async def precache_with_timeout():
|
||||
try:
|
||||
await asyncio.wait_for(precache_data(), timeout=60)
|
||||
except asyncio.TimeoutError:
|
||||
print("[precache] Precache timed out after 60 seconds")
|
||||
except Exception as e:
|
||||
print(f"[precache] Error during precache: {e}")
|
||||
|
||||
|
||||
# indexing DB data
|
||||
# async def indexing():
|
||||
@@ -53,11 +62,8 @@ async def lifespan(_app):
|
||||
print("[lifespan] Starting application initialization")
|
||||
create_all_tables()
|
||||
|
||||
# schedule precaching in background to avoid blocking startup
|
||||
asyncio.create_task(
|
||||
asyncio.wait_for(precache_data(), timeout=60)
|
||||
.catch(asyncio.TimeoutError, lambda _: print("Precache timed out"))
|
||||
)
|
||||
# schedule precaching in background with timeout and error handling
|
||||
asyncio.create_task(precache_with_timeout())
|
||||
|
||||
await asyncio.gather(
|
||||
redis.connect(),
|
||||
|
Reference in New Issue
Block a user