diff options
author | sestinj <sestinj@gmail.com> | 2023-09-06 19:30:07 -0700 |
---|---|---|
committer | sestinj <sestinj@gmail.com> | 2023-09-06 19:30:07 -0700 |
commit | bd38794a02d46b70ee018bdd6cd11e3c207465fc (patch) | |
tree | a4d6607c75f965b82441addb80fb3b6ed12f9cda /continuedev/src/continuedev/server | |
parent | f4820c80bf98706545aa5b113781caf9b3288c08 (diff) | |
download | sncontinue-bd38794a02d46b70ee018bdd6cd11e3c207465fc.tar.gz sncontinue-bd38794a02d46b70ee018bdd6cd11e3c207465fc.tar.bz2 sncontinue-bd38794a02d46b70ee018bdd6cd11e3c207465fc.zip |
restart_meilisearch
Diffstat (limited to 'continuedev/src/continuedev/server')
-rw-r--r-- | continuedev/src/continuedev/server/meilisearch_server.py | 21 |
1 files changed, 20 insertions, 1 deletions
diff --git a/continuedev/src/continuedev/server/meilisearch_server.py b/continuedev/src/continuedev/server/meilisearch_server.py index 6aae8cc5..f3734470 100644 --- a/continuedev/src/continuedev/server/meilisearch_server.py +++ b/continuedev/src/continuedev/server/meilisearch_server.py @@ -77,12 +77,13 @@ async def ensure_meilisearch_installed() -> bool: except: pass existing_paths.remove(meilisearchPath) + + await download_meilisearch() # Clear the existing directories for p in existing_paths: shutil.rmtree(p, ignore_errors=True) - await download_meilisearch() return False @@ -155,3 +156,21 @@ def stop_meilisearch(): meilisearch_process.terminate() meilisearch_process.wait() meilisearch_process = None + + +import psutil + +def kill_proc(port): + for proc in psutil.process_iter(): + try: + for conns in proc.connections(kind='inet'): + if conns.laddr.port == port: + proc.send_signal(psutil.signal.SIGTERM) # or SIGKILL + except psutil.AccessDenied: + logger.warning(f"Failed to kill process on port {port}") + + +async def restart_meilisearch(): + stop_meilisearch() + kill_proc(7700) + await start_meilisearch()
\ No newline at end of file |