summaryrefslogtreecommitdiff
path: root/continuedev/src/continuedev/server
diff options
context:
space:
mode:
authorNate Sesti <33237525+sestinj@users.noreply.github.com>2023-09-16 22:08:01 -0700
committerGitHub <noreply@github.com>2023-09-16 22:08:01 -0700
commit7a86f6a41b16d94f676bf327d35fb768854becb4 (patch)
treed28d3fd8cc994452447ef19d23e5167ffc2c12c5 /continuedev/src/continuedev/server
parentdfbae3f6add30b47d2bd0ba34be89af60d9ab660 (diff)
downloadsncontinue-7a86f6a41b16d94f676bf327d35fb768854becb4.tar.gz
sncontinue-7a86f6a41b16d94f676bf327d35fb768854becb4.tar.bz2
sncontinue-7a86f6a41b16d94f676bf327d35fb768854becb4.zip
Refactor helper (#481)
* feat: :sparkles: add stop_tokens option to LLM * work on refactoring in headless mode * feat: :sparkles: headless mode refactors * chore: :fire: remove test.py
Diffstat (limited to 'continuedev/src/continuedev/server')
-rw-r--r--continuedev/src/continuedev/server/meilisearch_server.py19
1 files changed, 13 insertions, 6 deletions
diff --git a/continuedev/src/continuedev/server/meilisearch_server.py b/continuedev/src/continuedev/server/meilisearch_server.py
index f3734470..40d46b18 100644
--- a/continuedev/src/continuedev/server/meilisearch_server.py
+++ b/continuedev/src/continuedev/server/meilisearch_server.py
@@ -77,14 +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)
-
return False
return True
@@ -160,17 +159,25 @@ def stop_meilisearch():
import psutil
+
def kill_proc(port):
for proc in psutil.process_iter():
try:
- for conns in proc.connections(kind='inet'):
+ for conns in proc.connections(kind="inet"):
if conns.laddr.port == port:
- proc.send_signal(psutil.signal.SIGTERM) # or SIGKILL
+ proc.send_signal(psutil.signal.SIGTERM) # or SIGKILL
except psutil.AccessDenied:
- logger.warning(f"Failed to kill process on port {port}")
+ logger.warning(f"Failed to kill process on port {port} (access denied)")
+ return
+ except psutil.ZombieProcess:
+ logger.warning(f"Failed to kill process on port {port} (zombie process)")
+ return
+ except psutil.NoSuchProcess:
+ logger.warning(f"Failed to kill process on port {port} (no such process)")
+ return
async def restart_meilisearch():
stop_meilisearch()
kill_proc(7700)
- await start_meilisearch() \ No newline at end of file
+ await start_meilisearch()