diff options
author | Nate Sesti <sestinj@gmail.com> | 2023-08-11 13:42:59 -0700 |
---|---|---|
committer | Nate Sesti <sestinj@gmail.com> | 2023-08-11 13:42:59 -0700 |
commit | 4eaf254b3fa974ef8a7ab6b08418ea8283a4f22a (patch) | |
tree | 0e6789f8f80e08d0ae497f08c76baa9876bebc34 /continuedev/src/continuedev/server | |
parent | 1936f725d226bea2e13d5d88c1dd7a9a02ddd259 (diff) | |
parent | 48ee1334dfd21dbe55cf66f39da1249619103e81 (diff) | |
download | sncontinue-4eaf254b3fa974ef8a7ab6b08418ea8283a4f22a.tar.gz sncontinue-4eaf254b3fa974ef8a7ab6b08418ea8283a4f22a.tar.bz2 sncontinue-4eaf254b3fa974ef8a7ab6b08418ea8283a4f22a.zip |
Merge branch 'main' into ci-testing
Diffstat (limited to 'continuedev/src/continuedev/server')
-rw-r--r-- | continuedev/src/continuedev/server/meilisearch_server.py | 16 |
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. |