diff options
author | Nate Sesti <sestinj@gmail.com> | 2023-08-10 15:50:05 -0700 |
---|---|---|
committer | Nate Sesti <sestinj@gmail.com> | 2023-08-10 15:50:05 -0700 |
commit | 7ca3bea2990d3a1c84d5a544e72827242a78361c (patch) | |
tree | 75b8d073088da338904ed5527f39af3aa26b6a51 /continuedev/src/continuedev/server | |
parent | ac14b40bbd93ccea991bb81615ed5ea0a1f29a86 (diff) | |
download | sncontinue-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.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. |