summaryrefslogtreecommitdiff
path: root/continuedev/src/continuedev/server
diff options
context:
space:
mode:
authorNate Sesti <sestinj@gmail.com>2023-08-10 15:50:05 -0700
committerNate Sesti <sestinj@gmail.com>2023-08-10 15:50:05 -0700
commit7ca3bea2990d3a1c84d5a544e72827242a78361c (patch)
tree75b8d073088da338904ed5527f39af3aa26b6a51 /continuedev/src/continuedev/server
parentac14b40bbd93ccea991bb81615ed5ea0a1f29a86 (diff)
downloadsncontinue-7ca3bea2990d3a1c84d5a544e72827242a78361c.tar.gz
sncontinue-7ca3bea2990d3a1c84d5a544e72827242a78361c.tar.bz2
sncontinue-7ca3bea2990d3a1c84d5a544e72827242a78361c.zip
refactor: :recycle: load index in contextmanager.start, slight tweaks
Diffstat (limited to 'continuedev/src/continuedev/server')
-rw-r--r--continuedev/src/continuedev/server/meilisearch_server.py16
1 files changed, 14 insertions, 2 deletions
diff --git a/continuedev/src/continuedev/server/meilisearch_server.py b/continuedev/src/continuedev/server/meilisearch_server.py
index 7f460afc..f47c08ca 100644
--- a/continuedev/src/continuedev/server/meilisearch_server.py
+++ b/continuedev/src/continuedev/server/meilisearch_server.py
@@ -1,3 +1,4 @@
+import asyncio
import os
import shutil
import subprocess
@@ -58,15 +59,26 @@ async def check_meilisearch_running() -> bool:
async with Client('http://localhost:7700') as client:
try:
resp = await client.health()
- if resp["status"] != "available":
+ if resp.status != "available":
return False
return True
- except:
+ except Exception as e:
+ logger.debug(e)
return False
except Exception:
return False
+async def poll_meilisearch_running(frequency: int = 0.1) -> bool:
+ """
+ Polls MeiliSearch to see if it is running.
+ """
+ while True:
+ if await check_meilisearch_running():
+ return True
+ await asyncio.sleep(frequency)
+
+
async def start_meilisearch():
"""
Starts the MeiliSearch server, wait for it.