1. pre-import llama-index package (#247)

* 1. pre-import llama-index package
2. ensure all processes are killed when SIG_TERM is received

* feat: added comments for pre-import

agents/scripts/install_deps_and_build.sh

@@ -57,6 +57,10 @@ install_python_requirements() {
       fi
     done
   fi
+
+  # pre-import llama-index as it cloud download additional resources during the first import
+  echo "pre-import python modules..."
+  python3.10 -c "import llama_index.core;"
 }
 
 build_go_app() {

server/internal/http_server.go

@@ -461,6 +461,6 @@ func (s *HttpServer) Start() {
 
 	slog.Info("server start", "port", s.config.Port, logTag)
 
-	go cleanWorker()
+	go timeoutWorkers()
 	r.Run(fmt.Sprintf(":%s", s.config.Port))
 }

server/internal/worker.go

@@ -228,7 +228,7 @@ func (w *Worker) update(req *WorkerUpdateReq) (err error) {
 	return
 }
 
-func cleanWorker() {
+func timeoutWorkers() {
 	for {
 		for _, channelName := range workers.Keys() {
 			worker := workers.Get(channelName).(*Worker)
@@ -248,3 +248,15 @@ func cleanWorker() {
 		time.Sleep(workerCleanSleepSeconds * time.Second)
 	}
 }
+
+func CleanWorkers() {
+	for _, channelName := range workers.Keys() {
+		worker := workers.Get(channelName).(*Worker)
+		if err := worker.stop(uuid.New().String(), channelName.(string)); err != nil {
+			slog.Error("Worker cleanWorker failed", "err", err, "channelName", channelName, logTag)
+			continue
+		}
+
+		slog.Info("Worker cleanWorker success", "channelName", channelName, "worker", worker, logTag)
+	}
+}

server/main.go

@@ -1,9 +1,12 @@
 package main
 
 import (
+	"fmt"
 	"log/slog"
 	"os"
+	"os/signal"
 	"strconv"
+	"syscall"
 
 	"github.com/joho/godotenv"
 
@@ -51,6 +54,17 @@ func main() {
 		os.Exit(1)
 	}
 
+	// Set up signal handler to clean up all workers on Ctrl+C
+	sigs := make(chan os.Signal, 1)
+	signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)
+
+	go func() {
+		<-sigs
+		fmt.Println("Received interrupt signal, cleaning up workers...")
+		internal.CleanWorkers()
+		os.Exit(0)
+	}()
+
 	// Start server
 	httpServerConfig := &internal.HttpServerConfig{
 		AppId:                    agoraAppId,