From f19551a7cd2a58ac2ac18655a22a62c287d12fe8 Mon Sep 17 00:00:00 2001
From: FangYin Cheng <staneyffer@gmail.com>
Date: Fri, 1 Sep 2023 10:40:18 +0800
Subject: [PATCH] feat: Optimize code import time

---
 .env.template                                 |  6 +++
 pilot/__init__.py                             | 14 ++++--
 pilot/agent/json_fix_llm.py                   |  4 +-
 pilot/commands/command.py                     |  3 +-
 pilot/common/markdown_text.py                 |  3 +-
 pilot/common/schema.py                        |  1 -
 pilot/common/sql_database.py                  |  4 +-
 pilot/configs/config.py                       | 12 ++---
 pilot/configs/model_config.py                 | 25 ++++++-----
 pilot/connections/base.py                     |  1 -
 .../manages/connect_storage_duckdb.py         |  1 -
 pilot/conversation.py                         |  1 -
 pilot/log/json_handler.py                     |  3 --
 pilot/logs.py                                 |  8 +++-
 pilot/memory/chat_history/base.py             | 13 +-----
 pilot/memory/chat_history/duckdb_history.py   |  2 -
 pilot/memory/chat_history/mem_history.py      | 12 +----
 pilot/model/adapter.py                        |  7 +--
 pilot/model/cache/base.py                     |  3 --
 pilot/model/cli.py                            | 45 ++++++++++---------
 pilot/model/conversation.py                   |  2 +-
 pilot/model/inference.py                      |  2 -
 pilot/model/llm/llama_cpp/llama_cpp.py        |  2 +-
 pilot/model/llm/llm_utils.py                  |  8 +---
 pilot/model/llm_out/chatglm_llm.py            |  2 -
 pilot/model/llm_out/falcon_llm.py             |  1 -
 pilot/model/loader.py                         | 16 ++++---
 pilot/model/parameter.py                      |  4 +-
 pilot/model/worker/default_worker.py          |  9 ++--
 pilot/model/worker/embedding_worker.py        |  4 +-
 pilot/model/worker/manager.py                 | 16 +++----
 pilot/model/worker/remote_worker.py           | 15 ++++---
 pilot/openapi/api_view_model.py               |  2 +-
 pilot/openapi/base.py                         | 22 +--------
 pilot/openapi/editor_view_model.py            |  2 +-
 pilot/out_parser/base.py                      |  3 +-
 pilot/prompts/base.py                         |  7 +--
 pilot/prompts/example_base.py                 |  3 +-
 pilot/prompts/prompt_new.py                   |  6 +--
 pilot/prompts/prompt_registry.py              |  1 -
 pilot/prompts/prompt_template.py              |  2 +-
 pilot/scene/base_chat.py                      | 44 +++++-------------
 pilot/scene/base_message.py                   | 15 +------
 pilot/scene/chat_dashboard/chat.py            |  2 +-
 .../data_preparation/report_schma.py          |  6 +--
 pilot/scene/chat_dashboard/out_parser.py      |  6 +--
 .../chat_excel/excel_analyze/chat.py          |  8 +---
 pilot/scene/chat_db/auto_execute/chat.py      |  9 ----
 .../scene/chat_db/auto_execute/out_parser.py  |  5 +--
 pilot/scene/chat_db/auto_execute/prompt.py    |  2 +-
 .../chat_db/auto_execute/prompt_baichuan.py   |  2 +-
 pilot/scene/chat_db/data_loader.py            |  5 +--
 pilot/scene/chat_db/professional_qa/chat.py   |  7 ---
 .../chat_db/professional_qa/out_parser.py     | 10 +----
 pilot/scene/chat_db/professional_qa/prompt.py |  2 -
 pilot/scene/chat_execution/chat.py            |  7 +--
 pilot/scene/chat_execution/out_parser.py      |  3 --
 pilot/scene/chat_factory.py                   | 20 ++++-----
 .../inner_db_summary/out_parser.py            |  5 ---
 .../chat_knowledge/inner_db_summary/prompt.py |  2 -
 pilot/scene/chat_knowledge/v1/chat.py         | 14 ++----
 pilot/scene/chat_knowledge/v1/out_parser.py   |  5 ---
 pilot/scene/chat_knowledge/v1/prompt.py       |  3 --
 .../scene/chat_knowledge/v1/prompt_chatglm.py |  3 --
 pilot/scene/chat_normal/chat.py               |  8 +---
 pilot/scene/chat_normal/out_parser.py         |  5 ---
 pilot/scene/chat_normal/prompt.py             |  3 --
 pilot/scene/message.py                        | 11 +----
 pilot/server/base.py                          | 12 +----
 pilot/server/chat_adapter.py                  |  3 +-
 pilot/server/dbgpt_server.py                  | 15 ++-----
 pilot/server/knowledge/api.py                 |  1 -
 pilot/server/knowledge/chunk_db.py            |  4 +-
 pilot/server/knowledge/document_db.py         |  4 +-
 pilot/server/knowledge/service.py             | 10 ++++-
 pilot/server/knowledge/space_db.py            |  3 +-
 pilot/server/llmserver.py                     | 12 -----
 pilot/speech/__init__.py                      |  3 --
 pilot/summary/db_summary_client.py            | 24 ++++++----
 pilot/utils/api_utils.py                      |  6 ++-
 pilot/utils/utils.py                          | 22 +++++++--
 pilot/vector_store/chroma_store.py            |  3 +-
 pilot/vector_store/milvus_store.py            |  7 ++-
 83 files changed, 244 insertions(+), 394 deletions(-)

diff --git a/.env.template b/.env.template
index 64d3b2f67..77c94ad66 100644
--- a/.env.template
+++ b/.env.template
@@ -143,3 +143,9 @@ SUMMARY_CONFIG=FAST
 # CUDA_VISIBLE_DEVICES=0
 ## You can configure the maximum memory used by each GPU.
 # MAX_GPU_MEMORY=16Gib
+
+#*******************************************************************#
+#**                         LOG                                   **#
+#*******************************************************************#
+# FATAL, ERROR, WARNING, WARNING, INFO, DEBUG, NOTSET
+DBGPT_LOG_LEVEL=INFO
\ No newline at end of file
diff --git a/pilot/__init__.py b/pilot/__init__.py
index d207a5bc3..d72238c1d 100644
--- a/pilot/__init__.py
+++ b/pilot/__init__.py
@@ -1,4 +1,12 @@
-from pilot.embedding_engine import SourceEmbedding, register
-from pilot.embedding_engine import EmbeddingEngine, KnowledgeType
+# Old packages
+# __all__ = ["SourceEmbedding", "register", "EmbeddingEngine", "KnowledgeType"]
 
-__all__ = ["SourceEmbedding", "register", "EmbeddingEngine", "KnowledgeType"]
+__all__ = ["embedding_engine"]
+
+
+def __getattr__(name: str):
+    import importlib
+
+    if name in ["embedding_engine"]:
+        return importlib.import_module("." + name, __name__)
+    raise AttributeError(f"module {__name__!r} has no attribute {name!r}")
diff --git a/pilot/agent/json_fix_llm.py b/pilot/agent/json_fix_llm.py
index 800c2858a..aa7c4cec8 100644
--- a/pilot/agent/json_fix_llm.py
+++ b/pilot/agent/json_fix_llm.py
@@ -12,7 +12,7 @@ from pilot.json_utils.json_fix_general import (
     fix_invalid_escape,
 )
 from pilot.logs import logger
-from pilot.speech import say_text
+
 
 CFG = Config()
 
@@ -87,6 +87,8 @@ def correct_json(json_to_load: str) -> str:
 
 
 def attempt_to_fix_json_by_finding_outermost_brackets(json_string: str):
+    from pilot.speech.say import say_text
+
     if CFG.speak_mode and CFG.debug_mode:
         say_text(
             "I have received an invalid JSON response from the OpenAI API. "
diff --git a/pilot/commands/command.py b/pilot/commands/command.py
index 8838efff1..add82d292 100644
--- a/pilot/commands/command.py
+++ b/pilot/commands/command.py
@@ -7,7 +7,6 @@ from typing import Dict
 from pilot.commands.exception_not_commands import NotCommands
 from pilot.configs.config import Config
 from pilot.prompts.generator import PluginPromptGenerator
-from pilot.speech import say_text
 
 
 def _resolve_pathlike_command_args(command_args):
@@ -37,6 +36,8 @@ def execute_ai_response_json(
     Returns:
 
     """
+    from pilot.speech.say import say_text
+
     cfg = Config()
 
     command_name, arguments = get_command(ai_response)
diff --git a/pilot/common/markdown_text.py b/pilot/common/markdown_text.py
index 1244160fd..8c2130cab 100644
--- a/pilot/common/markdown_text.py
+++ b/pilot/common/markdown_text.py
@@ -1,8 +1,9 @@
 import markdown2
-import pandas as pd
 
 
 def datas_to_table_html(data):
+    import pandas as pd
+
     df = pd.DataFrame(data[1:], columns=data[0])
     table_style = """<style> 
         table{border-collapse:collapse;width:60%;height:80%;margin:0 auto;float:right;border: 1px solid #007bff; background-color:#CFE299}th,td{border:1px solid #ddd;padding:3px;text-align:center}th{background-color:#C9C3C7;color: #fff;font-weight: bold;}tr:nth-child(even){background-color:#7C9F4A}tr:hover{background-color:#333}
diff --git a/pilot/common/schema.py b/pilot/common/schema.py
index 75f9b05a5..327234072 100644
--- a/pilot/common/schema.py
+++ b/pilot/common/schema.py
@@ -1,5 +1,4 @@
 from enum import auto, Enum
-from typing import List, Any
 import os
 
 
diff --git a/pilot/common/sql_database.py b/pilot/common/sql_database.py
index 5fb2ef349..9e94bfabc 100644
--- a/pilot/common/sql_database.py
+++ b/pilot/common/sql_database.py
@@ -3,8 +3,6 @@ import sqlparse
 import regex as re
 import warnings
 from typing import Any, Iterable, List, Optional
-from pydantic import BaseModel, Field, root_validator, validator, Extra
-from abc import ABC, abstractmethod
 import sqlalchemy
 from sqlalchemy import (
     MetaData,
@@ -14,7 +12,7 @@ from sqlalchemy import (
     select,
     text,
 )
-from sqlalchemy.engine import CursorResult, Engine
+from sqlalchemy.engine import CursorResult
 from sqlalchemy.exc import ProgrammingError, SQLAlchemyError
 from sqlalchemy.schema import CreateTable
 from sqlalchemy.orm import sessionmaker, scoped_session
diff --git a/pilot/configs/config.py b/pilot/configs/config.py
index d4c3b3f8c..86af93561 100644
--- a/pilot/configs/config.py
+++ b/pilot/configs/config.py
@@ -4,12 +4,7 @@
 import os
 from typing import List
 
-import nltk
-from auto_gpt_plugin_template import AutoGPTPluginTemplate
-
 from pilot.singleton import Singleton
-from pilot.common.sql_database import Database
-from pilot.prompts.prompt_registry import PromptTemplateRegistry
 
 
 class Config(metaclass=Singleton):
@@ -78,6 +73,8 @@ class Config(metaclass=Singleton):
         )
         self.speak_mode = False
 
+        from pilot.prompts.prompt_registry import PromptTemplateRegistry
+
         self.prompt_template_registry = PromptTemplateRegistry()
         ### Related configuration of built-in commands
         self.command_registry = []
@@ -98,6 +95,8 @@ class Config(metaclass=Singleton):
         self.message_dir = os.getenv("MESSAGE_HISTORY_DIR", "../../message")
 
         ### The associated configuration parameters of the plug-in control the loading and use of the plug-in
+        from auto_gpt_plugin_template import AutoGPTPluginTemplate
+
         self.plugins: List[AutoGPTPluginTemplate] = []
         self.plugins_openai = []
         self.plugins_auto_load = os.getenv("AUTO_LOAD_PLUGIN", "True") == "True"
@@ -183,6 +182,9 @@ class Config(metaclass=Singleton):
 
         self.MAX_GPU_MEMORY = os.getenv("MAX_GPU_MEMORY", None)
 
+        ### Log level
+        self.DBGPT_LOG_LEVEL = os.getenv("DBGPT_LOG_LEVEL", "INFO")
+
     def set_debug_mode(self, value: bool) -> None:
         """Set the debug mode value"""
         self.debug_mode = value
diff --git a/pilot/configs/model_config.py b/pilot/configs/model_config.py
index 0fef54daf..517705edc 100644
--- a/pilot/configs/model_config.py
+++ b/pilot/configs/model_config.py
@@ -3,8 +3,7 @@
 
 import os
 
-import nltk
-import torch
+# import nltk
 
 ROOT_PATH = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 MODEL_PATH = os.path.join(ROOT_PATH, "models")
@@ -13,7 +12,7 @@ VECTORE_PATH = os.path.join(PILOT_PATH, "vector_store")
 LOGDIR = os.path.join(ROOT_PATH, "logs")
 DATASETS_DIR = os.path.join(PILOT_PATH, "datasets")
 DATA_DIR = os.path.join(PILOT_PATH, "data")
-nltk.data.path = [os.path.join(PILOT_PATH, "nltk_data")] + nltk.data.path
+# nltk.data.path = [os.path.join(PILOT_PATH, "nltk_data")] + nltk.data.path
 PLUGINS_DIR = os.path.join(ROOT_PATH, "plugins")
 FONT_DIR = os.path.join(PILOT_PATH, "fonts")
 
@@ -22,13 +21,19 @@ current_directory = os.getcwd()
 new_directory = PILOT_PATH
 os.chdir(new_directory)
 
-DEVICE = (
-    "cuda"
-    if torch.cuda.is_available()
-    else "mps"
-    if torch.backends.mps.is_available()
-    else "cpu"
-)
+
+def get_device() -> str:
+    import torch
+
+    return (
+        "cuda"
+        if torch.cuda.is_available()
+        else "mps"
+        if torch.backends.mps.is_available()
+        else "cpu"
+    )
+
+
 LLM_MODEL_CONFIG = {
     "flan-t5-base": os.path.join(MODEL_PATH, "flan-t5-base"),
     "vicuna-13b": os.path.join(MODEL_PATH, "vicuna-13b"),
diff --git a/pilot/connections/base.py b/pilot/connections/base.py
index 1cb3f465f..028f4f71e 100644
--- a/pilot/connections/base.py
+++ b/pilot/connections/base.py
@@ -3,7 +3,6 @@
 
 """We need to design a base class.  That other connector can Write with this"""
 from abc import ABC, abstractmethod
-from pydantic import BaseModel, Extra, Field, root_validator
 from typing import Any, Iterable, List, Optional
 
 
diff --git a/pilot/connections/manages/connect_storage_duckdb.py b/pilot/connections/manages/connect_storage_duckdb.py
index acacaffd7..bdf1602c1 100644
--- a/pilot/connections/manages/connect_storage_duckdb.py
+++ b/pilot/connections/manages/connect_storage_duckdb.py
@@ -1,6 +1,5 @@
 import os
 import duckdb
-from typing import List
 
 default_db_path = os.path.join(os.getcwd(), "message")
 duckdb_path = os.getenv("DB_DUCKDB_PATH", default_db_path + "/connect_config.db")
diff --git a/pilot/conversation.py b/pilot/conversation.py
index 2fab65dba..aa31a3b23 100644
--- a/pilot/conversation.py
+++ b/pilot/conversation.py
@@ -2,7 +2,6 @@
 # -*- coding:utf-8 -*-
 
 import dataclasses
-import uuid
 from enum import auto, Enum
 from typing import List, Any
 from pilot.language.translation_handler import get_lang_text
diff --git a/pilot/log/json_handler.py b/pilot/log/json_handler.py
index 51ae9ae03..e45ee9f13 100644
--- a/pilot/log/json_handler.py
+++ b/pilot/log/json_handler.py
@@ -12,9 +12,6 @@ class JsonFileHandler(logging.FileHandler):
             json.dump(json_data, f, ensure_ascii=False, indent=4)
 
 
-import logging
-
-
 class JsonFormatter(logging.Formatter):
     def format(self, record):
         return record.msg
diff --git a/pilot/logs.py b/pilot/logs.py
index cf5d5603f..673799307 100644
--- a/pilot/logs.py
+++ b/pilot/logs.py
@@ -8,9 +8,7 @@ from typing import Any
 
 from colorama import Fore, Style
 
-from pilot.log.json_handler import JsonFileHandler, JsonFormatter
 from pilot.singleton import Singleton
-from pilot.speech import say_text
 
 
 class Logger(metaclass=Singleton):
@@ -86,6 +84,8 @@ class Logger(metaclass=Singleton):
     def typewriter_log(
         self, title="", title_color="", content="", speak_text=False, level=logging.INFO
     ):
+        from pilot.speech.say import say_text
+
         if speak_text and self.speak_mode:
             say_text(f"{title}. {content}")
 
@@ -159,6 +159,8 @@ class Logger(metaclass=Singleton):
         self.typewriter_log("DOUBLE CHECK CONFIGURATION", Fore.YELLOW, additionalText)
 
     def log_json(self, data: Any, file_name: str) -> None:
+        from pilot.log.json_handler import JsonFileHandler, JsonFormatter
+
         # Define log directory
         this_files_dir_path = os.path.dirname(__file__)
         log_dir = os.path.join(this_files_dir_path, "../logs")
@@ -255,6 +257,8 @@ def print_assistant_thoughts(
     assistant_reply_json_valid: object,
     speak_mode: bool = False,
 ) -> None:
+    from pilot.speech.say import say_text
+
     assistant_thoughts_reasoning = None
     assistant_thoughts_plan = None
     assistant_thoughts_speak = None
diff --git a/pilot/memory/chat_history/base.py b/pilot/memory/chat_history/base.py
index 0f79fb19e..d9d1cba29 100644
--- a/pilot/memory/chat_history/base.py
+++ b/pilot/memory/chat_history/base.py
@@ -1,18 +1,7 @@
 from __future__ import annotations
 
-from pydantic import BaseModel, Field, root_validator, validator, Extra
 from abc import ABC, abstractmethod
-from typing import (
-    Any,
-    Dict,
-    Generic,
-    List,
-    NamedTuple,
-    Optional,
-    Sequence,
-    TypeVar,
-    Union,
-)
+from typing import List
 
 from pilot.scene.message import OnceConversation
 
diff --git a/pilot/memory/chat_history/duckdb_history.py b/pilot/memory/chat_history/duckdb_history.py
index 09f4612df..cbc21f03a 100644
--- a/pilot/memory/chat_history/duckdb_history.py
+++ b/pilot/memory/chat_history/duckdb_history.py
@@ -7,9 +7,7 @@ from pilot.configs.config import Config
 from pilot.memory.chat_history.base import BaseChatHistoryMemory
 from pilot.scene.message import (
     OnceConversation,
-    conversation_from_dict,
     _conversation_to_dic,
-    conversations_to_dict,
 )
 from pilot.common.formatting import MyEncoder
 
diff --git a/pilot/memory/chat_history/mem_history.py b/pilot/memory/chat_history/mem_history.py
index c53595d3d..2e832041f 100644
--- a/pilot/memory/chat_history/mem_history.py
+++ b/pilot/memory/chat_history/mem_history.py
@@ -1,17 +1,9 @@
 from typing import List
-import json
-import os
-import datetime
 from pilot.memory.chat_history.base import BaseChatHistoryMemory
-from pathlib import Path
 
 from pilot.configs.config import Config
-from pilot.scene.message import (
-    OnceConversation,
-    conversation_from_dict,
-    conversations_to_dict,
-)
-from pilot.common.custom_data_structure import FixedSizeDict, FixedSizeList
+from pilot.scene.message import OnceConversation
+from pilot.common.custom_data_structure import FixedSizeDict
 
 CFG = Config()
 
diff --git a/pilot/model/adapter.py b/pilot/model/adapter.py
index 8ec0075ea..cf20742dd 100644
--- a/pilot/model/adapter.py
+++ b/pilot/model/adapter.py
@@ -1,7 +1,6 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
 
-import torch
 import os
 import re
 from pathlib import Path
@@ -14,7 +13,7 @@ from transformers import (
     LlamaTokenizer,
 )
 from pilot.model.parameter import ModelParameters, LlamaCppModelParameters
-from pilot.configs.model_config import DEVICE
+from pilot.configs.model_config import get_device
 from pilot.configs.config import Config
 from pilot.logs import logger
 
@@ -147,9 +146,11 @@ class ChatGLMAdapater(BaseLLMAdaper):
         return "chatglm" in model_path
 
     def loader(self, model_path: str, from_pretrained_kwargs: dict):
+        import torch
+
         tokenizer = AutoTokenizer.from_pretrained(model_path, trust_remote_code=True)
 
-        if DEVICE != "cuda":
+        if get_device() != "cuda":
             model = AutoModel.from_pretrained(
                 model_path, trust_remote_code=True, **from_pretrained_kwargs
             ).float()
diff --git a/pilot/model/cache/base.py b/pilot/model/cache/base.py
index d0b814f84..904241de7 100644
--- a/pilot/model/cache/base.py
+++ b/pilot/model/cache/base.py
@@ -1,6 +1,3 @@
-import json
-import hashlib
-from typing import Any, Dict
 from abc import ABC, abstractmethod
 
 
diff --git a/pilot/model/cli.py b/pilot/model/cli.py
index 9208522d7..f716089f9 100644
--- a/pilot/model/cli.py
+++ b/pilot/model/cli.py
@@ -2,11 +2,7 @@ import click
 import functools
 
 from pilot.model.controller.registry import ModelRegistryClient
-from pilot.model.worker.manager import (
-    RemoteWorkerManager,
-    WorkerApplyRequest,
-    WorkerApplyType,
-)
+from pilot.model.base import WorkerApplyType
 from pilot.model.parameter import (
     ModelControllerParameters,
     ModelWorkerParameters,
@@ -15,12 +11,14 @@ from pilot.model.parameter import (
 from pilot.utils import get_or_create_event_loop
 from pilot.utils.parameter_utils import EnvArgumentParser
 
+MODEL_CONTROLLER_ADDRESS = "http://127.0.0.1:8000"
+
 
 @click.group("model")
 @click.option(
     "--address",
     type=str,
-    default="http://127.0.0.1:8000",
+    default=MODEL_CONTROLLER_ADDRESS,
     required=False,
     show_default=True,
     help=(
@@ -28,24 +26,25 @@ from pilot.utils.parameter_utils import EnvArgumentParser
         "Just support light deploy model"
     ),
 )
-def model_cli_group():
+def model_cli_group(address: str):
     """Clients that manage model serving"""
-    pass
+    global MODEL_CONTROLLER_ADDRESS
+    MODEL_CONTROLLER_ADDRESS = address
 
 
 @model_cli_group.command()
 @click.option(
-    "--model-name", type=str, default=None, required=False, help=("The name of model")
+    "--model_name", type=str, default=None, required=False, help=("The name of model")
 )
 @click.option(
-    "--model-type", type=str, default="llm", required=False, help=("The type of model")
+    "--model_type", type=str, default="llm", required=False, help=("The type of model")
 )
-def list(address: str, model_name: str, model_type: str):
+def list(model_name: str, model_type: str):
     """List model instances"""
     from prettytable import PrettyTable
 
     loop = get_or_create_event_loop()
-    registry = ModelRegistryClient(address)
+    registry = ModelRegistryClient(MODEL_CONTROLLER_ADDRESS)
 
     if not model_name:
         instances = loop.run_until_complete(registry.get_all_model_instances())
@@ -88,14 +87,14 @@ def list(address: str, model_name: str, model_type: str):
 
 def add_model_options(func):
     @click.option(
-        "--model-name",
+        "--model_name",
         type=str,
         default=None,
         required=True,
         help=("The name of model"),
     )
     @click.option(
-        "--model-type",
+        "--model_type",
         type=str,
         default="llm",
         required=False,
@@ -110,23 +109,27 @@ def add_model_options(func):
 
 @model_cli_group.command()
 @add_model_options
-def stop(address: str, model_name: str, model_type: str):
+def stop(model_name: str, model_type: str):
     """Stop model instances"""
-    worker_apply(address, model_name, model_type, WorkerApplyType.STOP)
+    worker_apply(MODEL_CONTROLLER_ADDRESS, model_name, model_type, WorkerApplyType.STOP)
 
 
 @model_cli_group.command()
 @add_model_options
-def start(address: str, model_name: str, model_type: str):
+def start(model_name: str, model_type: str):
     """Start model instances"""
-    worker_apply(address, model_name, model_type, WorkerApplyType.START)
+    worker_apply(
+        MODEL_CONTROLLER_ADDRESS, model_name, model_type, WorkerApplyType.START
+    )
 
 
 @model_cli_group.command()
 @add_model_options
-def restart(address: str, model_name: str, model_type: str):
+def restart(model_name: str, model_type: str):
     """Restart model instances"""
-    worker_apply(address, model_name, model_type, WorkerApplyType.RESTART)
+    worker_apply(
+        MODEL_CONTROLLER_ADDRESS, model_name, model_type, WorkerApplyType.RESTART
+    )
 
 
 # @model_cli_group.command()
@@ -139,6 +142,8 @@ def restart(address: str, model_name: str, model_type: str):
 def worker_apply(
     address: str, model_name: str, model_type: str, apply_type: WorkerApplyType
 ):
+    from pilot.model.worker.manager import RemoteWorkerManager, WorkerApplyRequest
+
     loop = get_or_create_event_loop()
     registry = ModelRegistryClient(address)
     worker_manager = RemoteWorkerManager(registry)
diff --git a/pilot/model/conversation.py b/pilot/model/conversation.py
index 8508881b7..f3b85842f 100644
--- a/pilot/model/conversation.py
+++ b/pilot/model/conversation.py
@@ -6,7 +6,7 @@ Conversation prompt templates.
 
 import dataclasses
 from enum import auto, IntEnum
-from typing import List, Any, Dict, Callable
+from typing import List, Dict, Callable
 
 
 class SeparatorStyle(IntEnum):
diff --git a/pilot/model/inference.py b/pilot/model/inference.py
index cbbd04339..1cf681ebe 100644
--- a/pilot/model/inference.py
+++ b/pilot/model/inference.py
@@ -9,8 +9,6 @@ from typing import Iterable, Dict
 
 import torch
 
-import torch
-
 from transformers.generation.logits_process import (
     LogitsProcessorList,
     RepetitionPenaltyLogitsProcessor,
diff --git a/pilot/model/llm/llama_cpp/llama_cpp.py b/pilot/model/llm/llama_cpp/llama_cpp.py
index 5029d9192..5b7431a9e 100644
--- a/pilot/model/llm/llama_cpp/llama_cpp.py
+++ b/pilot/model/llm/llama_cpp/llama_cpp.py
@@ -2,7 +2,7 @@
 Fork from text-generation-webui https://github.com/oobabooga/text-generation-webui/blob/main/modules/llamacpp_model.py
 """
 import re
-from typing import Dict, Any
+from typing import Dict
 import torch
 import llama_cpp
 
diff --git a/pilot/model/llm/llm_utils.py b/pilot/model/llm/llm_utils.py
index e2bf631cc..8a9feda65 100644
--- a/pilot/model/llm/llm_utils.py
+++ b/pilot/model/llm/llm_utils.py
@@ -7,13 +7,7 @@ import time
 from typing import Optional
 
 from pilot.configs.config import Config
-from pilot.conversation import (
-    Conversation,
-    auto_dbgpt_one_shot,
-    conv_one_shot,
-    conv_templates,
-)
-from pilot.model.llm.base import Message
+from pilot.conversation import Conversation
 
 
 # TODO Rewrite this
diff --git a/pilot/model/llm_out/chatglm_llm.py b/pilot/model/llm_out/chatglm_llm.py
index 968101c56..ba1e61499 100644
--- a/pilot/model/llm_out/chatglm_llm.py
+++ b/pilot/model/llm_out/chatglm_llm.py
@@ -3,11 +3,9 @@
 
 from typing import List
 import re
-import copy
 
 import torch
 
-from pilot.conversation import ROLE_ASSISTANT, ROLE_USER
 from pilot.scene.base_message import ModelMessage, _parse_model_messages
 
 # TODO move sep to scene prompt of model
diff --git a/pilot/model/llm_out/falcon_llm.py b/pilot/model/llm_out/falcon_llm.py
index 53eaffdfb..12aebc6e9 100644
--- a/pilot/model/llm_out/falcon_llm.py
+++ b/pilot/model/llm_out/falcon_llm.py
@@ -1,5 +1,4 @@
 import torch
-import copy
 from threading import Thread
 from transformers import TextIteratorStreamer, StoppingCriteriaList, StoppingCriteria
 
diff --git a/pilot/model/loader.py b/pilot/model/loader.py
index 79b4c1049..f30a9811d 100644
--- a/pilot/model/loader.py
+++ b/pilot/model/loader.py
@@ -2,16 +2,13 @@
 # -*- coding: utf-8 -*-
 
 from typing import Optional, Dict
-import torch
 
-from pilot.configs.model_config import DEVICE
+from pilot.configs.model_config import get_device
 from pilot.model.adapter import get_llm_model_adapter, BaseLLMAdaper, ModelType
-from pilot.model.compression import compress_module
 from pilot.model.parameter import (
     ModelParameters,
     LlamaCppModelParameters,
 )
-from pilot.model.llm.monkey_patch import replace_llama_attn_with_non_inplace_operations
 from pilot.utils import get_gpu_memory
 from pilot.utils.parameter_utils import EnvArgumentParser, _genenv_ignoring_key_case
 from pilot.logs import logger
@@ -67,7 +64,7 @@ class ModelLoader:
     """
 
     def __init__(self, model_path: str, model_name: str = None) -> None:
-        self.device = DEVICE
+        self.device = get_device()
         self.model_path = model_path
         self.model_name = model_name
         self.prompt_template: str = None
@@ -127,6 +124,9 @@ class ModelLoader:
 
 
 def huggingface_loader(llm_adapter: BaseLLMAdaper, model_params: ModelParameters):
+    import torch
+    from pilot.model.compression import compress_module
+
     device = model_params.device
     max_memory = None
 
@@ -156,6 +156,10 @@ def huggingface_loader(llm_adapter: BaseLLMAdaper, model_params: ModelParameters
 
     elif device == "mps":
         kwargs = {"torch_dtype": torch.float16}
+        from pilot.model.llm.monkey_patch import (
+            replace_llama_attn_with_non_inplace_operations,
+        )
+
         replace_llama_attn_with_non_inplace_operations()
     else:
         raise ValueError(f"Invalid device: {device}")
@@ -200,6 +204,8 @@ def load_huggingface_quantization_model(
     kwargs: Dict,
     max_memory: Dict[int, str],
 ):
+    import torch
+
     try:
         from accelerate import init_empty_weights
         from accelerate.utils import infer_auto_device_map
diff --git a/pilot/model/parameter.py b/pilot/model/parameter.py
index c47af4e21..bddea6663 100644
--- a/pilot/model/parameter.py
+++ b/pilot/model/parameter.py
@@ -1,8 +1,8 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
-from dataclasses import dataclass, field, fields, MISSING
+from dataclasses import dataclass, field
 from enum import Enum
-from typing import Any, Dict, Optional
+from typing import Dict, Optional
 
 from pilot.model.conversation import conv_templates
 from pilot.utils.parameter_utils import BaseParameters
diff --git a/pilot/model/worker/default_worker.py b/pilot/model/worker/default_worker.py
index 034b3cffa..fad8d0b5e 100644
--- a/pilot/model/worker/default_worker.py
+++ b/pilot/model/worker/default_worker.py
@@ -2,8 +2,7 @@ import logging
 import platform
 from typing import Dict, Iterator, List
 
-import torch
-from pilot.configs.model_config import DEVICE
+from pilot.configs.model_config import get_device
 from pilot.model.adapter import get_llm_model_adapter, BaseLLMAdaper
 from pilot.model.base import ModelOutput
 from pilot.model.loader import ModelLoader, _get_model_real_path
@@ -63,7 +62,7 @@ class DefaultModelWorker(ModelWorker):
             model_type=model_type,
         )
         if not model_params.device:
-            model_params.device = DEVICE
+            model_params.device = get_device()
             logger.info(
                 f"[DefaultModelWorker] Parameters of device is None, use {model_params.device}"
             )
@@ -88,6 +87,8 @@ class DefaultModelWorker(ModelWorker):
         _clear_torch_cache(self._model_params.device)
 
     def generate_stream(self, params: Dict) -> Iterator[ModelOutput]:
+        import torch
+
         try:
             # params adaptation
             params, model_context = self.llm_chat_adapter.model_adaptation(
@@ -95,7 +96,7 @@ class DefaultModelWorker(ModelWorker):
             )
 
             for output in self.generate_stream_func(
-                self.model, self.tokenizer, params, DEVICE, self.context_len
+                self.model, self.tokenizer, params, get_device(), self.context_len
             ):
                 # Please do not open the output in production!
                 # The gpt4all thread shares stdout with the parent process,
diff --git a/pilot/model/worker/embedding_worker.py b/pilot/model/worker/embedding_worker.py
index 75bda74bc..0fd3c4593 100644
--- a/pilot/model/worker/embedding_worker.py
+++ b/pilot/model/worker/embedding_worker.py
@@ -1,7 +1,7 @@
 import logging
 from typing import Dict, List, Type
 
-from pilot.configs.model_config import DEVICE
+from pilot.configs.model_config import get_device
 from pilot.model.loader import _get_model_real_path
 from pilot.model.parameter import (
     EmbeddingModelParameters,
@@ -55,7 +55,7 @@ class EmbeddingsModelWorker(ModelWorker):
             model_path=self.model_path,
         )
         if not model_params.device:
-            model_params.device = DEVICE
+            model_params.device = get_device()
             logger.info(
                 f"[EmbeddingsModelWorker] Parameters of device is None, use {model_params.device}"
             )
diff --git a/pilot/model/worker/manager.py b/pilot/model/worker/manager.py
index 89063de8b..f39aba585 100644
--- a/pilot/model/worker/manager.py
+++ b/pilot/model/worker/manager.py
@@ -1,5 +1,4 @@
 import asyncio
-import httpx
 import itertools
 import json
 import os
@@ -7,26 +6,21 @@ import random
 import time
 from abc import ABC, abstractmethod
 from concurrent.futures import Future, ThreadPoolExecutor
-from dataclasses import asdict, dataclass, field
+from dataclasses import asdict, dataclass
 from datetime import datetime
 from typing import Awaitable, Callable, Dict, Iterator, List, Optional
 
-import uvicorn
 from fastapi import APIRouter, FastAPI, Request
 from fastapi.responses import StreamingResponse
 from pilot.configs.model_config import LOGDIR
 from pilot.model.base import (
     ModelInstance,
     ModelOutput,
-    WorkerApplyType,
     WorkerApplyOutput,
+    WorkerApplyType,
 )
 from pilot.model.controller.registry import ModelRegistry
-from pilot.model.parameter import (
-    ModelParameters,
-    ModelWorkerParameters,
-    WorkerType,
-)
+from pilot.model.parameter import ModelParameters, ModelWorkerParameters, WorkerType
 from pilot.model.worker.base import ModelWorker
 from pilot.scene.base_message import ModelMessage
 from pilot.utils import build_logger
@@ -431,6 +425,8 @@ class RemoteWorkerManager(LocalWorkerManager):
         return worker_instances
 
     async def worker_apply(self, apply_req: WorkerApplyRequest) -> WorkerApplyOutput:
+        import httpx
+
         async def _remote_apply_func(worker_run_data: WorkerRunData):
             worker_addr = worker_run_data.worker.worker_addr
             async with httpx.AsyncClient() as client:
@@ -700,6 +696,8 @@ def run_worker_manager(
         app.include_router(router, prefix="/api")
 
     if not embedded_mod:
+        import uvicorn
+
         uvicorn.run(
             app, host=worker_params.host, port=worker_params.port, log_level="info"
         )
diff --git a/pilot/model/worker/remote_worker.py b/pilot/model/worker/remote_worker.py
index 8712da0ca..c7538f6fc 100644
--- a/pilot/model/worker/remote_worker.py
+++ b/pilot/model/worker/remote_worker.py
@@ -1,7 +1,6 @@
 import json
 from typing import Dict, Iterator, List
-
-import httpx
+import logging
 from pilot.model.base import ModelOutput
 from pilot.model.parameter import ModelParameters
 from pilot.model.worker.base import ModelWorker
@@ -10,7 +9,8 @@ from pilot.model.worker.base import ModelWorker
 class RemoteModelWorker(ModelWorker):
     def __init__(self) -> None:
         self.headers = {}
-        self.timeout = 60
+        # TODO Configured by ModelParameters
+        self.timeout = 180
         self.host = None
         self.port = None
 
@@ -44,7 +44,9 @@ class RemoteModelWorker(ModelWorker):
 
     async def async_generate_stream(self, params: Dict) -> Iterator[ModelOutput]:
         """Asynchronous generate stream"""
-        print(f"Send async_generate_stream, params: {params}")
+        import httpx
+
+        logging.debug(f"Send async_generate_stream, params: {params}")
         async with httpx.AsyncClient() as client:
             delimiter = b"\0"
             buffer = b""
@@ -71,8 +73,9 @@ class RemoteModelWorker(ModelWorker):
 
     async def async_generate(self, params: Dict) -> ModelOutput:
         """Asynchronous generate non stream"""
-        print(f"Send async_generate_stream, params: {params}")
+        import httpx
 
+        logging.debug(f"Send async_generate_stream, params: {params}")
         async with httpx.AsyncClient() as client:
             response = await client.post(
                 self.worker_addr + "/generate",
@@ -88,6 +91,8 @@ class RemoteModelWorker(ModelWorker):
 
     async def async_embeddings(self, params: Dict) -> List[List[float]]:
         """Asynchronous get embeddings for input"""
+        import httpx
+
         async with httpx.AsyncClient() as client:
             response = await client.post(
                 self.worker_addr + "/embeddings",
diff --git a/pilot/openapi/api_view_model.py b/pilot/openapi/api_view_model.py
index f4c0de53e..92dbc1e1f 100644
--- a/pilot/openapi/api_view_model.py
+++ b/pilot/openapi/api_view_model.py
@@ -1,5 +1,5 @@
 from pydantic import BaseModel, Field
-from typing import TypeVar, Union, List, Generic, Any
+from typing import TypeVar, Generic, Any
 
 T = TypeVar("T")
 
diff --git a/pilot/openapi/base.py b/pilot/openapi/base.py
index 1e389543f..506254ec7 100644
--- a/pilot/openapi/base.py
+++ b/pilot/openapi/base.py
@@ -1,24 +1,6 @@
-from fastapi import (
-    APIRouter,
-    Request,
-    Body,
-    status,
-    HTTPException,
-    Response,
-    BackgroundTasks,
-)
-
-from fastapi.responses import JSONResponse, HTMLResponse
-from fastapi.responses import StreamingResponse, FileResponse
-from fastapi.encoders import jsonable_encoder
+from fastapi import Request
 from fastapi.exceptions import RequestValidationError
-
-from pilot.openapi.api_view_model import (
-    Result,
-    ConversationVo,
-    MessageVo,
-    ChatSceneVo,
-)
+from pilot.openapi.api_view_model import Result
 
 
 async def validation_exception_handler(request: Request, exc: RequestValidationError):
diff --git a/pilot/openapi/editor_view_model.py b/pilot/openapi/editor_view_model.py
index bbff0227f..369ae20ba 100644
--- a/pilot/openapi/editor_view_model.py
+++ b/pilot/openapi/editor_view_model.py
@@ -1,5 +1,5 @@
 from pydantic import BaseModel, Field
-from typing import TypeVar, Union, List, Generic, Any
+from typing import List, Any
 
 
 class DbField(BaseModel):
diff --git a/pilot/out_parser/base.py b/pilot/out_parser/base.py
index 5cd86573a..2d080c3fe 100644
--- a/pilot/out_parser/base.py
+++ b/pilot/out_parser/base.py
@@ -1,8 +1,7 @@
 from __future__ import annotations
 
 import json
-import re
-from abc import ABC, abstractmethod
+from abc import ABC
 from dataclasses import asdict
 from typing import Any, Dict, TypeVar, Union
 
diff --git a/pilot/prompts/base.py b/pilot/prompts/base.py
index 12a97e94f..5176cdc34 100644
--- a/pilot/prompts/base.py
+++ b/pilot/prompts/base.py
@@ -1,10 +1,7 @@
-import json
 from abc import ABC, abstractmethod
-from pathlib import Path
-from typing import Any, Callable, Dict, List, Mapping, Optional, Set, Union
+from typing import List
 
-import yaml
-from pydantic import BaseModel, Extra, Field, root_validator
+from pydantic import BaseModel
 
 from pilot.scene.base_message import BaseMessage, HumanMessage, AIMessage, SystemMessage
 
diff --git a/pilot/prompts/example_base.py b/pilot/prompts/example_base.py
index f7844a4d7..36872ba69 100644
--- a/pilot/prompts/example_base.py
+++ b/pilot/prompts/example_base.py
@@ -1,7 +1,6 @@
 from abc import ABC, abstractmethod
 from pydantic import BaseModel
-from typing import Any, Callable, Dict, List, Mapping, Optional, Set, Union
-
+from typing import List
 from pilot.common.schema import ExampleType
 
 
diff --git a/pilot/prompts/prompt_new.py b/pilot/prompts/prompt_new.py
index 84943050c..e10cee35e 100644
--- a/pilot/prompts/prompt_new.py
+++ b/pilot/prompts/prompt_new.py
@@ -1,7 +1,7 @@
 import json
-from abc import ABC, abstractmethod
-from typing import Any, Callable, Dict, List, Mapping, Optional, Set, Union
-from pydantic import BaseModel, Extra, Field, root_validator
+from abc import ABC
+from typing import Any, Callable, Dict, List, Optional
+from pydantic import BaseModel
 
 
 from pilot.common.formatting import formatter, no_strict_formatter
diff --git a/pilot/prompts/prompt_registry.py b/pilot/prompts/prompt_registry.py
index 1e4aeb135..e35282b6f 100644
--- a/pilot/prompts/prompt_registry.py
+++ b/pilot/prompts/prompt_registry.py
@@ -3,7 +3,6 @@
 
 from collections import defaultdict
 from typing import Dict, List
-import json
 
 _DEFAULT_MODEL_KEY = "___default_prompt_template_model_key__"
 _DEFUALT_LANGUAGE_KEY = "___default_prompt_template_language_key__"
diff --git a/pilot/prompts/prompt_template.py b/pilot/prompts/prompt_template.py
index 53f66a9da..4397cd2e4 100644
--- a/pilot/prompts/prompt_template.py
+++ b/pilot/prompts/prompt_template.py
@@ -11,7 +11,7 @@ from pydantic import BaseModel, Extra, Field, root_validator
 
 from pilot.out_parser.base import BaseOutputParser
 from pilot.prompts.base import PromptValue
-from pilot.scene.base_message import HumanMessage, AIMessage, SystemMessage, BaseMessage
+from pilot.scene.base_message import HumanMessage, BaseMessage
 from pilot.common.formatting import formatter
 
 
diff --git a/pilot/scene/base_chat.py b/pilot/scene/base_chat.py
index e2c9a03b0..92001005b 100644
--- a/pilot/scene/base_chat.py
+++ b/pilot/scene/base_chat.py
@@ -1,44 +1,20 @@
-import time
-from abc import ABC, abstractmethod
 import datetime
 import traceback
 import warnings
-import json
-from pydantic import BaseModel, Field, root_validator, validator, Extra
-from typing import (
-    Any,
-    Dict,
-    Generic,
-    List,
-    NamedTuple,
-    Optional,
-    Sequence,
-    TypeVar,
-    Union,
-)
-import requests
-from urllib.parse import urljoin
+from abc import ABC, abstractmethod
+from typing import Any, List
 
-import pilot.configs.config
-from pilot.scene.message import OnceConversation
-from pilot.prompts.prompt_new import PromptTemplate
+from pilot.configs.config import Config
+from pilot.configs.model_config import LOGDIR
 from pilot.memory.chat_history.base import BaseChatHistoryMemory
+from pilot.memory.chat_history.duckdb_history import DuckdbHistoryMemory
 from pilot.memory.chat_history.file_history import FileHistoryMemory
 from pilot.memory.chat_history.mem_history import MemHistoryMemory
-from pilot.memory.chat_history.duckdb_history import DuckdbHistoryMemory
-
-from pilot.configs.model_config import LOGDIR, DATASETS_DIR
-from pilot.utils import build_logger, server_error_msg, get_or_create_event_loop
-from pilot.scene.base_message import (
-    BaseMessage,
-    SystemMessage,
-    HumanMessage,
-    AIMessage,
-    ViewMessage,
-    ModelMessage,
-    ModelMessageRoleType,
-)
-from pilot.configs.config import Config
+from pilot.prompts.prompt_new import PromptTemplate
+from pilot.scene.base_message import ModelMessage, ModelMessageRoleType
+from pilot.scene.message import OnceConversation
+from pilot.utils import build_logger, get_or_create_event_loop
+from pydantic import Extra
 
 logger = build_logger("BaseChat", LOGDIR + "BaseChat.log")
 headers = {"User-Agent": "dbgpt Client"}
diff --git a/pilot/scene/base_message.py b/pilot/scene/base_message.py
index ea39cb09c..eeb42a285 100644
--- a/pilot/scene/base_message.py
+++ b/pilot/scene/base_message.py
@@ -1,20 +1,9 @@
 from __future__ import annotations
 
 from abc import ABC, abstractmethod
-from typing import (
-    Any,
-    Dict,
-    Generic,
-    List,
-    Tuple,
-    NamedTuple,
-    Optional,
-    Sequence,
-    TypeVar,
-    Union,
-)
+from typing import Any, Dict, List, Tuple, Optional
 
-from pydantic import BaseModel, Extra, Field, root_validator
+from pydantic import BaseModel, Field, root_validator
 
 
 class PromptValue(BaseModel, ABC):
diff --git a/pilot/scene/chat_dashboard/chat.py b/pilot/scene/chat_dashboard/chat.py
index 2769d123a..a40ae768f 100644
--- a/pilot/scene/chat_dashboard/chat.py
+++ b/pilot/scene/chat_dashboard/chat.py
@@ -3,7 +3,7 @@ import os
 import uuid
 from typing import List
 
-from pilot.scene.base_chat import BaseChat, logger
+from pilot.scene.base_chat import BaseChat
 from pilot.scene.base import ChatScene
 from pilot.configs.config import Config
 from pilot.scene.chat_dashboard.data_preparation.report_schma import (
diff --git a/pilot/scene/chat_dashboard/data_preparation/report_schma.py b/pilot/scene/chat_dashboard/data_preparation/report_schma.py
index 09388f4bd..fae554d95 100644
--- a/pilot/scene/chat_dashboard/data_preparation/report_schma.py
+++ b/pilot/scene/chat_dashboard/data_preparation/report_schma.py
@@ -1,7 +1,5 @@
-import json
-from pydantic import BaseModel, Field
-from typing import TypeVar, Union, List, Generic, Any
-from dataclasses import dataclass, asdict
+from pydantic import BaseModel
+from typing import List, Any
 
 
 class ValueItem(BaseModel):
diff --git a/pilot/scene/chat_dashboard/out_parser.py b/pilot/scene/chat_dashboard/out_parser.py
index 7f799f585..78f0318a3 100644
--- a/pilot/scene/chat_dashboard/out_parser.py
+++ b/pilot/scene/chat_dashboard/out_parser.py
@@ -1,9 +1,5 @@
 import json
-import re
-from dataclasses import dataclass, asdict
-from abc import ABC, abstractmethod
-from typing import Dict, NamedTuple, List
-import pandas as pd
+from typing import NamedTuple, List
 from pilot.utils import build_logger
 from pilot.out_parser.base import BaseOutputParser, T
 from pilot.configs.model_config import LOGDIR
diff --git a/pilot/scene/chat_data/chat_excel/excel_analyze/chat.py b/pilot/scene/chat_data/chat_excel/excel_analyze/chat.py
index 0bfb9f915..dac412b98 100644
--- a/pilot/scene/chat_data/chat_excel/excel_analyze/chat.py
+++ b/pilot/scene/chat_data/chat_excel/excel_analyze/chat.py
@@ -3,17 +3,11 @@ import os
 
 
 from typing import List, Any, Dict
-from pilot.scene.base_message import (
-    HumanMessage,
-    ViewMessage,
-)
 from pilot.scene.base_chat import BaseChat, logger
 from pilot.scene.base import ChatScene
 from pilot.common.sql_database import Database
 from pilot.configs.config import Config
-from pilot.common.markdown_text import (
-    generate_htm_table,
-)
+
 from pilot.scene.chat_data.chat_excel.excel_analyze.prompt import prompt
 from pilot.scene.chat_data.chat_excel.excel_reader import ExcelReader
 from pilot.scene.chat_data.chat_excel.excel_learning.chat import ExcelLearning
diff --git a/pilot/scene/chat_db/auto_execute/chat.py b/pilot/scene/chat_db/auto_execute/chat.py
index 595e65e2e..785881746 100644
--- a/pilot/scene/chat_db/auto_execute/chat.py
+++ b/pilot/scene/chat_db/auto_execute/chat.py
@@ -1,16 +1,7 @@
-import json
-
-from pilot.scene.base_message import (
-    HumanMessage,
-    ViewMessage,
-)
 from pilot.scene.base_chat import BaseChat
 from pilot.scene.base import ChatScene
 from pilot.common.sql_database import Database
 from pilot.configs.config import Config
-from pilot.common.markdown_text import (
-    generate_htm_table,
-)
 from pilot.scene.chat_db.auto_execute.prompt import prompt
 
 CFG = Config()
diff --git a/pilot/scene/chat_db/auto_execute/out_parser.py b/pilot/scene/chat_db/auto_execute/out_parser.py
index f19903fc8..8a79bca33 100644
--- a/pilot/scene/chat_db/auto_execute/out_parser.py
+++ b/pilot/scene/chat_db/auto_execute/out_parser.py
@@ -1,8 +1,5 @@
 import json
-import re
-from abc import ABC, abstractmethod
 from typing import Dict, NamedTuple
-import pandas as pd
 from pilot.utils import build_logger
 from pilot.out_parser.base import BaseOutputParser, T
 from pilot.configs.model_config import LOGDIR
@@ -36,6 +33,8 @@ class DbChatOutputParser(BaseOutputParser):
         return SqlAction(sql, thoughts)
 
     def parse_view_response(self, speak, data) -> str:
+        import pandas as pd
+
         ### tool out data to table view
         data_loader = DbDataLoader()
         if len(data) <= 1:
diff --git a/pilot/scene/chat_db/auto_execute/prompt.py b/pilot/scene/chat_db/auto_execute/prompt.py
index a2737aa4f..abc889cec 100644
--- a/pilot/scene/chat_db/auto_execute/prompt.py
+++ b/pilot/scene/chat_db/auto_execute/prompt.py
@@ -2,7 +2,7 @@ import json
 from pilot.prompts.prompt_new import PromptTemplate
 from pilot.configs.config import Config
 from pilot.scene.base import ChatScene
-from pilot.scene.chat_db.auto_execute.out_parser import DbChatOutputParser, SqlAction
+from pilot.scene.chat_db.auto_execute.out_parser import DbChatOutputParser
 from pilot.common.schema import SeparatorStyle
 from pilot.scene.chat_db.auto_execute.example import sql_data_example
 
diff --git a/pilot/scene/chat_db/auto_execute/prompt_baichuan.py b/pilot/scene/chat_db/auto_execute/prompt_baichuan.py
index ed0c2c8b2..95aa962fa 100644
--- a/pilot/scene/chat_db/auto_execute/prompt_baichuan.py
+++ b/pilot/scene/chat_db/auto_execute/prompt_baichuan.py
@@ -5,7 +5,7 @@ import json
 from pilot.prompts.prompt_new import PromptTemplate
 from pilot.configs.config import Config
 from pilot.scene.base import ChatScene
-from pilot.scene.chat_db.auto_execute.out_parser import DbChatOutputParser, SqlAction
+from pilot.scene.chat_db.auto_execute.out_parser import DbChatOutputParser
 from pilot.common.schema import SeparatorStyle
 from pilot.scene.chat_db.auto_execute.example import sql_data_example
 
diff --git a/pilot/scene/chat_db/data_loader.py b/pilot/scene/chat_db/data_loader.py
index b1f9ea93d..ddb02d1c9 100644
--- a/pilot/scene/chat_db/data_loader.py
+++ b/pilot/scene/chat_db/data_loader.py
@@ -1,8 +1,7 @@
-import pandas as pd
-
-
 class DbDataLoader:
     def get_table_view_by_conn(self, data, speak):
+        import pandas as pd
+
         ### tool out data to table view
         if len(data) <= 1:
             data.insert(0, ["result"])
diff --git a/pilot/scene/chat_db/professional_qa/chat.py b/pilot/scene/chat_db/professional_qa/chat.py
index 18b587acf..1c246700c 100644
--- a/pilot/scene/chat_db/professional_qa/chat.py
+++ b/pilot/scene/chat_db/professional_qa/chat.py
@@ -1,14 +1,7 @@
-from pilot.scene.base_message import (
-    HumanMessage,
-    ViewMessage,
-)
 from pilot.scene.base_chat import BaseChat
 from pilot.scene.base import ChatScene
 from pilot.common.sql_database import Database
 from pilot.configs.config import Config
-from pilot.common.markdown_text import (
-    generate_htm_table,
-)
 from pilot.scene.chat_db.professional_qa.prompt import prompt
 
 CFG = Config()
diff --git a/pilot/scene/chat_db/professional_qa/out_parser.py b/pilot/scene/chat_db/professional_qa/out_parser.py
index e5edc9b20..0c15aedbe 100644
--- a/pilot/scene/chat_db/professional_qa/out_parser.py
+++ b/pilot/scene/chat_db/professional_qa/out_parser.py
@@ -1,12 +1,6 @@
-import json
-import re
-from abc import ABC, abstractmethod
-from typing import Dict, NamedTuple
-import pandas as pd
-from pilot.utils import build_logger
-from pilot.out_parser.base import BaseOutputParser, T
 from pilot.configs.model_config import LOGDIR
-
+from pilot.out_parser.base import BaseOutputParser, T
+from pilot.utils import build_logger
 
 logger = build_logger("webserver", LOGDIR + "DbChatOutputParser.log")
 
diff --git a/pilot/scene/chat_db/professional_qa/prompt.py b/pilot/scene/chat_db/professional_qa/prompt.py
index c46382b8e..ca4110398 100644
--- a/pilot/scene/chat_db/professional_qa/prompt.py
+++ b/pilot/scene/chat_db/professional_qa/prompt.py
@@ -1,5 +1,3 @@
-import json
-import importlib
 from pilot.prompts.prompt_new import PromptTemplate
 from pilot.configs.config import Config
 from pilot.scene.base import ChatScene
diff --git a/pilot/scene/chat_execution/chat.py b/pilot/scene/chat_execution/chat.py
index 43727f613..031d4afb1 100644
--- a/pilot/scene/chat_execution/chat.py
+++ b/pilot/scene/chat_execution/chat.py
@@ -1,11 +1,6 @@
-import requests
-import datetime
-from urllib.parse import urljoin
 from typing import List
-import traceback
 
-from pilot.scene.base_chat import BaseChat, logger, headers
-from pilot.scene.message import OnceConversation
+from pilot.scene.base_chat import BaseChat
 from pilot.scene.base import ChatScene
 from pilot.configs.config import Config
 from pilot.commands.command import execute_command
diff --git a/pilot/scene/chat_execution/out_parser.py b/pilot/scene/chat_execution/out_parser.py
index 3db6ecff4..8e1186c0a 100644
--- a/pilot/scene/chat_execution/out_parser.py
+++ b/pilot/scene/chat_execution/out_parser.py
@@ -1,8 +1,5 @@
 import json
-import re
-from abc import ABC, abstractmethod
 from typing import Dict, NamedTuple
-import pandas as pd
 from pilot.utils import build_logger
 from pilot.out_parser.base import BaseOutputParser, T
 from pilot.configs.model_config import LOGDIR
diff --git a/pilot/scene/chat_factory.py b/pilot/scene/chat_factory.py
index d7aad8b28..ad2da3b3f 100644
--- a/pilot/scene/chat_factory.py
+++ b/pilot/scene/chat_factory.py
@@ -1,20 +1,20 @@
 from pilot.scene.base_chat import BaseChat
 from pilot.singleton import Singleton
-import inspect
-import importlib
-from pilot.scene.chat_execution.chat import ChatWithPlugin
-from pilot.scene.chat_normal.chat import ChatNormal
-from pilot.scene.chat_db.professional_qa.chat import ChatWithDbQA
-from pilot.scene.chat_db.auto_execute.chat import ChatWithDbAutoExecute
-from pilot.scene.chat_dashboard.chat import ChatDashboard
-from pilot.scene.chat_knowledge.v1.chat import ChatKnowledge
-from pilot.scene.chat_knowledge.inner_db_summary.chat import InnerChatDBSummary
-from pilot.scene.chat_data.chat_excel.excel_analyze.chat import ChatExcel
 
 
 class ChatFactory(metaclass=Singleton):
     @staticmethod
     def get_implementation(chat_mode, **kwargs):
+        # Lazy loading
+        from pilot.scene.chat_execution.chat import ChatWithPlugin
+        from pilot.scene.chat_normal.chat import ChatNormal
+        from pilot.scene.chat_db.professional_qa.chat import ChatWithDbQA
+        from pilot.scene.chat_db.auto_execute.chat import ChatWithDbAutoExecute
+        from pilot.scene.chat_dashboard.chat import ChatDashboard
+        from pilot.scene.chat_knowledge.v1.chat import ChatKnowledge
+        from pilot.scene.chat_knowledge.inner_db_summary.chat import InnerChatDBSummary
+        from pilot.scene.chat_data.chat_excel.excel_analyze.chat import ChatExcel
+
         chat_classes = BaseChat.__subclasses__()
         implementation = None
         for cls in chat_classes:
diff --git a/pilot/scene/chat_knowledge/inner_db_summary/out_parser.py b/pilot/scene/chat_knowledge/inner_db_summary/out_parser.py
index 5731857e8..4f3065334 100644
--- a/pilot/scene/chat_knowledge/inner_db_summary/out_parser.py
+++ b/pilot/scene/chat_knowledge/inner_db_summary/out_parser.py
@@ -1,8 +1,3 @@
-import json
-import re
-from abc import ABC, abstractmethod
-from typing import Dict, NamedTuple
-import pandas as pd
 from pilot.utils import build_logger
 from pilot.out_parser.base import BaseOutputParser, T
 from pilot.configs.model_config import LOGDIR
diff --git a/pilot/scene/chat_knowledge/inner_db_summary/prompt.py b/pilot/scene/chat_knowledge/inner_db_summary/prompt.py
index 6153a7b5f..924fab2c6 100644
--- a/pilot/scene/chat_knowledge/inner_db_summary/prompt.py
+++ b/pilot/scene/chat_knowledge/inner_db_summary/prompt.py
@@ -1,5 +1,3 @@
-import builtins
-import importlib
 import json
 
 from pilot.prompts.prompt_new import PromptTemplate
diff --git a/pilot/scene/chat_knowledge/v1/chat.py b/pilot/scene/chat_knowledge/v1/chat.py
index e4213f447..dedb72f6c 100644
--- a/pilot/scene/chat_knowledge/v1/chat.py
+++ b/pilot/scene/chat_knowledge/v1/chat.py
@@ -1,25 +1,15 @@
 from chromadb.errors import NoIndexException
 
-from pilot.scene.base_chat import BaseChat, logger, headers
+from pilot.scene.base_chat import BaseChat
 from pilot.scene.base import ChatScene
-from pilot.common.sql_database import Database
 from pilot.configs.config import Config
 
-from pilot.common.markdown_text import (
-    generate_markdown_table,
-    generate_htm_table,
-    datas_to_table_html,
-)
-
 from pilot.configs.model_config import (
-    DATASETS_DIR,
     KNOWLEDGE_UPLOAD_ROOT_PATH,
     LLM_MODEL_CONFIG,
-    LOGDIR,
 )
 
 from pilot.scene.chat_knowledge.v1.prompt import prompt
-from pilot.embedding_engine.embedding_engine import EmbeddingEngine
 from pilot.server.knowledge.service import KnowledgeService
 
 CFG = Config()
@@ -32,6 +22,8 @@ class ChatKnowledge(BaseChat):
 
     def __init__(self, chat_session_id, user_input, select_param: str = None):
         """ """
+        from pilot.embedding_engine.embedding_engine import EmbeddingEngine
+
         self.knowledge_space = select_param
         super().__init__(
             chat_mode=ChatScene.ChatKnowledge,
diff --git a/pilot/scene/chat_knowledge/v1/out_parser.py b/pilot/scene/chat_knowledge/v1/out_parser.py
index e5edc9b20..ba8cd428a 100644
--- a/pilot/scene/chat_knowledge/v1/out_parser.py
+++ b/pilot/scene/chat_knowledge/v1/out_parser.py
@@ -1,8 +1,3 @@
-import json
-import re
-from abc import ABC, abstractmethod
-from typing import Dict, NamedTuple
-import pandas as pd
 from pilot.utils import build_logger
 from pilot.out_parser.base import BaseOutputParser, T
 from pilot.configs.model_config import LOGDIR
diff --git a/pilot/scene/chat_knowledge/v1/prompt.py b/pilot/scene/chat_knowledge/v1/prompt.py
index d82984aee..6788d6d35 100644
--- a/pilot/scene/chat_knowledge/v1/prompt.py
+++ b/pilot/scene/chat_knowledge/v1/prompt.py
@@ -1,6 +1,3 @@
-import builtins
-import importlib
-
 from pilot.prompts.prompt_new import PromptTemplate
 from pilot.configs.config import Config
 from pilot.scene.base import ChatScene
diff --git a/pilot/scene/chat_knowledge/v1/prompt_chatglm.py b/pilot/scene/chat_knowledge/v1/prompt_chatglm.py
index 44353c9ff..7f66c1e6f 100644
--- a/pilot/scene/chat_knowledge/v1/prompt_chatglm.py
+++ b/pilot/scene/chat_knowledge/v1/prompt_chatglm.py
@@ -1,6 +1,3 @@
-import builtins
-import importlib
-
 from pilot.prompts.prompt_new import PromptTemplate
 from pilot.configs.config import Config
 from pilot.scene.base import ChatScene
diff --git a/pilot/scene/chat_normal/chat.py b/pilot/scene/chat_normal/chat.py
index 531319366..56fca35e5 100644
--- a/pilot/scene/chat_normal/chat.py
+++ b/pilot/scene/chat_normal/chat.py
@@ -1,13 +1,7 @@
-from pilot.scene.base_chat import BaseChat, logger, headers
+from pilot.scene.base_chat import BaseChat
 from pilot.scene.base import ChatScene
-from pilot.common.sql_database import Database
 from pilot.configs.config import Config
 
-from pilot.common.markdown_text import (
-    generate_markdown_table,
-    generate_htm_table,
-    datas_to_table_html,
-)
 from pilot.scene.chat_normal.prompt import prompt
 
 CFG = Config()
diff --git a/pilot/scene/chat_normal/out_parser.py b/pilot/scene/chat_normal/out_parser.py
index e5edc9b20..ba8cd428a 100644
--- a/pilot/scene/chat_normal/out_parser.py
+++ b/pilot/scene/chat_normal/out_parser.py
@@ -1,8 +1,3 @@
-import json
-import re
-from abc import ABC, abstractmethod
-from typing import Dict, NamedTuple
-import pandas as pd
 from pilot.utils import build_logger
 from pilot.out_parser.base import BaseOutputParser, T
 from pilot.configs.model_config import LOGDIR
diff --git a/pilot/scene/chat_normal/prompt.py b/pilot/scene/chat_normal/prompt.py
index ce0c08234..ad0724874 100644
--- a/pilot/scene/chat_normal/prompt.py
+++ b/pilot/scene/chat_normal/prompt.py
@@ -1,6 +1,3 @@
-import builtins
-import importlib
-
 from pilot.prompts.prompt_new import PromptTemplate
 from pilot.configs.config import Config
 from pilot.scene.base import ChatScene
diff --git a/pilot/scene/message.py b/pilot/scene/message.py
index 73a141988..af52780f9 100644
--- a/pilot/scene/message.py
+++ b/pilot/scene/message.py
@@ -1,13 +1,6 @@
 from __future__ import annotations
-from datetime import datetime, timedelta
-from pydantic import BaseModel, Field, root_validator, validator
-from abc import ABC, abstractmethod
-from typing import (
-    Any,
-    Dict,
-    Generic,
-    List,
-)
+from datetime import datetime
+from typing import List
 
 from pilot.scene.base_message import (
     BaseMessage,
diff --git a/pilot/server/base.py b/pilot/server/base.py
index 3dfaa1c7e..1b7ce6ecd 100644
--- a/pilot/server/base.py
+++ b/pilot/server/base.py
@@ -1,28 +1,18 @@
 import signal
 import os
 import threading
-import traceback
 import sys
 
 from pilot.summary.db_summary_client import DBSummaryClient
 from pilot.commands.command_mange import CommandRegistry
 from pilot.configs.config import Config
 
-# from pilot.configs.model_config import (
-#     DATASETS_DIR,
-#     KNOWLEDGE_UPLOAD_ROOT_PATH,
-#     LLM_MODEL_CONFIG,
-#     LOGDIR,
-# )
-from pilot.common.plugins import scan_plugins, load_native_plugins
-from pilot.utils import build_logger
+from pilot.common.plugins import scan_plugins
 from pilot.connections.manages.connection_manager import ConnectManager
 
 ROOT_PATH = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 sys.path.append(ROOT_PATH)
 
-# logger = build_logger("webserver", LOGDIR + "webserver.log")
-
 
 def signal_handler(sig, frame):
     print("in order to avoid chroma db atexit problem")
diff --git a/pilot/server/chat_adapter.py b/pilot/server/chat_adapter.py
index 0bc53e8fd..466a96c0f 100644
--- a/pilot/server/chat_adapter.py
+++ b/pilot/server/chat_adapter.py
@@ -3,7 +3,6 @@
 
 from functools import cache
 from typing import List, Dict, Tuple
-from pilot.model.llm_out.vicuna_base_llm import generate_stream
 from pilot.model.conversation import Conversation, get_conv_template
 from pilot.scene.base_message import ModelMessage, ModelMessageRoleType
 
@@ -131,6 +130,8 @@ class VicunaChatAdapter(BaseChatAdpter):
         return None
 
     def get_generate_stream_func(self, model_path: str):
+        from pilot.model.llm_out.vicuna_base_llm import generate_stream
+
         if self._is_llama2_based(model_path):
             return super().get_generate_stream_func(model_path)
         return generate_stream
diff --git a/pilot/server/dbgpt_server.py b/pilot/server/dbgpt_server.py
index 86ca49330..8a172120f 100644
--- a/pilot/server/dbgpt_server.py
+++ b/pilot/server/dbgpt_server.py
@@ -1,7 +1,4 @@
-import atexit
-import traceback
 import os
-import shutil
 import argparse
 import sys
 import logging
@@ -11,7 +8,6 @@ sys.path.append(ROOT_PATH)
 import signal
 from pilot.configs.config import Config
 from pilot.configs.model_config import LLM_MODEL_CONFIG
-from pilot.utils import build_logger
 
 from pilot.server.base import server_init
 
@@ -28,14 +24,11 @@ from pilot.openapi.base import validation_exception_handler
 from pilot.openapi.api_v1.editor.api_editor_v1 import router as api_editor_route_v1
 from pilot.commands.disply_type.show_chart_gen import static_message_img_path
 from pilot.model.worker.manager import initialize_worker_manager_in_client
-
-logging.basicConfig(level=logging.INFO, encoding="utf-8")
+from pilot.utils.utils import setup_logging
 
 static_file_path = os.path.join(os.getcwd(), "server/static")
 
-
 CFG = Config()
-# logger = build_logger("webserver", LOGDIR + "webserver.log")
 
 
 def signal_handler():
@@ -102,7 +95,7 @@ if __name__ == "__main__":
     parser.add_argument("--port", type=int, default=5000)
     parser.add_argument("--concurrency-count", type=int, default=10)
     parser.add_argument("--share", default=False, action="store_true")
-    parser.add_argument("--log-level", type=str, default="info")
+    parser.add_argument("--log-level", type=str, default=None)
     parser.add_argument(
         "-light",
         "--light",
@@ -113,6 +106,7 @@ if __name__ == "__main__":
 
     # init server config
     args = parser.parse_args()
+    setup_logging(logging_level=args.log_level)
     server_init(args)
 
     model_path = LLM_MODEL_CONFIG[CFG.LLM_MODEL]
@@ -137,6 +131,5 @@ if __name__ == "__main__":
     mount_static_files(app)
     import uvicorn
 
-    logging.basicConfig(level=logging.INFO, encoding="utf-8")
-    uvicorn.run(app, host="0.0.0.0", port=args.port, log_level=args.log_level)
+    uvicorn.run(app, host="0.0.0.0", port=args.port, log_level="info")
     signal.signal(signal.SIGINT, signal_handler())
diff --git a/pilot/server/knowledge/api.py b/pilot/server/knowledge/api.py
index be141b8f2..c2113ab3b 100644
--- a/pilot/server/knowledge/api.py
+++ b/pilot/server/knowledge/api.py
@@ -1,7 +1,6 @@
 import os
 import shutil
 import tempfile
-from tempfile import NamedTemporaryFile
 
 from fastapi import APIRouter, File, UploadFile, Form
 
diff --git a/pilot/server/knowledge/chunk_db.py b/pilot/server/knowledge/chunk_db.py
index 7ca9bd461..e5147a73e 100644
--- a/pilot/server/knowledge/chunk_db.py
+++ b/pilot/server/knowledge/chunk_db.py
@@ -1,8 +1,8 @@
 from datetime import datetime
 from typing import List
 
-from sqlalchemy import Column, String, DateTime, Integer, Text, create_engine, func
-from sqlalchemy.orm import declarative_base, sessionmaker
+from sqlalchemy import Column, String, DateTime, Integer, Text, func
+from sqlalchemy.orm import declarative_base
 
 from pilot.configs.config import Config
 from pilot.connections.rdbms.base_dao import BaseDao
diff --git a/pilot/server/knowledge/document_db.py b/pilot/server/knowledge/document_db.py
index 1a6c4f8ac..42b7ac8f0 100644
--- a/pilot/server/knowledge/document_db.py
+++ b/pilot/server/knowledge/document_db.py
@@ -1,7 +1,7 @@
 from datetime import datetime
 
-from sqlalchemy import Column, String, DateTime, Integer, Text, create_engine, func
-from sqlalchemy.orm import declarative_base, sessionmaker
+from sqlalchemy import Column, String, DateTime, Integer, Text, func
+from sqlalchemy.orm import declarative_base
 
 from pilot.configs.config import Config
 from pilot.connections.rdbms.base_dao import BaseDao
diff --git a/pilot/server/knowledge/service.py b/pilot/server/knowledge/service.py
index 4310038c5..9faad31ed 100644
--- a/pilot/server/knowledge/service.py
+++ b/pilot/server/knowledge/service.py
@@ -2,12 +2,10 @@ import json
 import threading
 from datetime import datetime
 
-from langchain.text_splitter import RecursiveCharacterTextSplitter, SpacyTextSplitter
 from pilot.vector_store.connector import VectorStoreConnector
 
 from pilot.configs.config import Config
 from pilot.configs.model_config import LLM_MODEL_CONFIG, KNOWLEDGE_UPLOAD_ROOT_PATH
-from pilot.embedding_engine.embedding_engine import EmbeddingEngine
 from pilot.logs import logger
 from pilot.server.knowledge.chunk_db import (
     DocumentChunkEntity,
@@ -152,6 +150,14 @@ class KnowledgeService:
     """sync knowledge document chunk into vector store"""
 
     def sync_knowledge_document(self, space_name, doc_ids):
+        from pilot.embedding_engine.embedding_engine import EmbeddingEngine
+        from langchain.text_splitter import (
+            RecursiveCharacterTextSplitter,
+            SpacyTextSplitter,
+        )
+
+        # import langchain is very very slow!!!
+
         for doc_id in doc_ids:
             query = KnowledgeDocumentEntity(
                 id=doc_id,
diff --git a/pilot/server/knowledge/space_db.py b/pilot/server/knowledge/space_db.py
index cb2640b00..a47a5ffae 100644
--- a/pilot/server/knowledge/space_db.py
+++ b/pilot/server/knowledge/space_db.py
@@ -1,8 +1,7 @@
 from datetime import datetime
 
-from sqlalchemy import Column, Integer, Text, String, DateTime, create_engine
+from sqlalchemy import Column, Integer, Text, String, DateTime
 from sqlalchemy.ext.declarative import declarative_base
-from sqlalchemy.orm import sessionmaker
 
 from pilot.configs.config import Config
 from pilot.server.knowledge.request.request import KnowledgeSpaceRequest
diff --git a/pilot/server/llmserver.py b/pilot/server/llmserver.py
index 7b7a2e90c..3fdabc002 100644
--- a/pilot/server/llmserver.py
+++ b/pilot/server/llmserver.py
@@ -4,9 +4,6 @@
 import os
 import sys
 
-global_counter = 0
-model_semaphore = None
-
 ROOT_PATH = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 sys.path.append(ROOT_PATH)
 
@@ -17,15 +14,6 @@ from pilot.model.worker.manager import run_worker_manager
 CFG = Config()
 
 model_path = LLM_MODEL_CONFIG[CFG.LLM_MODEL]
-# worker = ModelWorker(model_path=model_path, model_name=CFG.LLM_MODEL, device=DEVICE)
-
-# @app.post("/embedding")
-# def embeddings(prompt_request: EmbeddingRequest):
-#     params = {"prompt": prompt_request.prompt}
-#     print("Received prompt: ", params["prompt"])
-#     output = worker.get_embeddings(params["prompt"])
-#     return {"response": [float(x) for x in output]}
-
 
 if __name__ == "__main__":
     run_worker_manager(
diff --git a/pilot/speech/__init__.py b/pilot/speech/__init__.py
index 58bfda398..e69de29bb 100644
--- a/pilot/speech/__init__.py
+++ b/pilot/speech/__init__.py
@@ -1,3 +0,0 @@
-from pilot.speech.say import say_text
-
-__all__ = ["say_text"]
diff --git a/pilot/summary/db_summary_client.py b/pilot/summary/db_summary_client.py
index a0b31b6a8..964580591 100644
--- a/pilot/summary/db_summary_client.py
+++ b/pilot/summary/db_summary_client.py
@@ -1,21 +1,19 @@
 import json
 import uuid
 
-from langchain.embeddings import HuggingFaceEmbeddings, logger
-
+from pilot.common.schema import DBType
 from pilot.configs.config import Config
-from pilot.configs.model_config import LLM_MODEL_CONFIG, KNOWLEDGE_UPLOAD_ROOT_PATH
+from pilot.configs.model_config import (
+    KNOWLEDGE_UPLOAD_ROOT_PATH,
+    LLM_MODEL_CONFIG,
+    LOGDIR,
+)
 from pilot.scene.base import ChatScene
 from pilot.scene.base_chat import BaseChat
-from pilot.embedding_engine.embedding_engine import EmbeddingEngine
-from pilot.embedding_engine.string_embedding import StringEmbedding
-from pilot.summary.rdbms_db_summary import RdbmsSummary
 from pilot.scene.chat_factory import ChatFactory
-from pilot.common.schema import DBType
-from pilot.configs.model_config import LOGDIR
+from pilot.summary.rdbms_db_summary import RdbmsSummary
 from pilot.utils import build_logger
 
-
 logger = build_logger("db_summary", LOGDIR + "db_summary.log")
 
 
@@ -33,6 +31,8 @@ class DBSummaryClient:
 
     def db_summary_embedding(self, dbname, db_type):
         """put db profile and table profile summary into vector store"""
+        from langchain.embeddings import HuggingFaceEmbeddings
+        from pilot.embedding_engine.string_embedding import StringEmbedding
 
         db_summary_client = RdbmsSummary(dbname, db_type)
         embeddings = HuggingFaceEmbeddings(
@@ -82,6 +82,8 @@ class DBSummaryClient:
         logger.info("db summary embedding success")
 
     def get_db_summary(self, dbname, query, topk):
+        from pilot.embedding_engine.embedding_engine import EmbeddingEngine
+
         vector_store_config = {
             "vector_store_name": dbname + "_profile",
             "vector_store_type": CFG.VECTOR_STORE_TYPE,
@@ -97,6 +99,8 @@ class DBSummaryClient:
 
     def get_similar_tables(self, dbname, query, topk):
         """get user query related tables info"""
+        from pilot.embedding_engine.embedding_engine import EmbeddingEngine
+
         vector_store_config = {
             "vector_store_name": dbname + "_summary",
             "chroma_persist_path": KNOWLEDGE_UPLOAD_ROOT_PATH,
@@ -149,6 +153,8 @@ class DBSummaryClient:
                 )
 
     def init_db_profile(self, db_summary_client, dbname, embeddings):
+        from pilot.embedding_engine.string_embedding import StringEmbedding
+
         profile_store_config = {
             "vector_store_name": dbname + "_profile",
             "chroma_persist_path": KNOWLEDGE_UPLOAD_ROOT_PATH,
diff --git a/pilot/utils/api_utils.py b/pilot/utils/api_utils.py
index ea2bef6ef..58dbd1a9c 100644
--- a/pilot/utils/api_utils.py
+++ b/pilot/utils/api_utils.py
@@ -1,6 +1,4 @@
-import httpx
 from inspect import signature
-import typing_inspect
 import logging
 from typing import get_type_hints, List, Type, TypeVar, Union, Optional, Tuple
 from dataclasses import is_dataclass, asdict
@@ -9,6 +7,8 @@ T = TypeVar("T")
 
 
 def _extract_dataclass_from_generic(type_hint: Type[T]) -> Union[Type[T], None]:
+    import typing_inspect
+
     """Extract actual dataclass from generic type hints like List[dataclass], Optional[dataclass], etc."""
     if typing_inspect.is_generic_type(type_hint) and typing_inspect.get_args(type_hint):
         return typing_inspect.get_args(type_hint)[0]
@@ -30,6 +30,8 @@ def _api_remote(path, method="GET"):
         sig = signature(func)
 
         async def wrapper(self, *args, **kwargs):
+            import httpx
+
             base_url = self.base_url  # Get base_url from class instance
 
             bound = sig.bind(self, *args, **kwargs)
diff --git a/pilot/utils/utils.py b/pilot/utils/utils.py
index 5b4ed064a..2e205c275 100644
--- a/pilot/utils/utils.py
+++ b/pilot/utils/utils.py
@@ -16,6 +16,22 @@ server_error_msg = (
 handler = None
 
 
+def _get_logging_level() -> str:
+    return os.getenv("DBGPT_LOG_LEVEL", "INFO")
+
+
+def setup_logging(logging_level=None, logger_name: str = None):
+    if not logging_level:
+        logging_level = _get_logging_level()
+    if type(logging_level) is str:
+        logging_level = logging.getLevelName(logging_level.upper())
+    if logger_name:
+        logger = logging.getLogger(logger_name)
+        logger.setLevel(logging_level)
+    else:
+        logging.basicConfig(level=logging_level, encoding="utf-8")
+
+
 def get_gpu_memory(max_gpus=None):
     import torch
 
@@ -47,7 +63,7 @@ def build_logger(logger_name, logger_filename):
 
     # Set the format of root handlers
     if not logging.getLogger().handlers:
-        logging.basicConfig(level=logging.INFO, encoding="utf-8")
+        setup_logging()
     logging.getLogger().handlers[0].setFormatter(formatter)
 
     # Redirect stdout and stderr to loggers
@@ -73,11 +89,11 @@ def build_logger(logger_name, logger_filename):
         for name, item in logging.root.manager.loggerDict.items():
             if isinstance(item, logging.Logger):
                 item.addHandler(handler)
-    logging.basicConfig(level=logging.INFO, encoding="utf-8")
+    setup_logging()
 
     # Get logger
     logger = logging.getLogger(logger_name)
-    logger.setLevel(logging.INFO)
+    setup_logging(logger_name=logger_name)
 
     return logger
 
diff --git a/pilot/vector_store/chroma_store.py b/pilot/vector_store/chroma_store.py
index d53071caa..59ac254b6 100644
--- a/pilot/vector_store/chroma_store.py
+++ b/pilot/vector_store/chroma_store.py
@@ -2,7 +2,6 @@ import os
 from typing import Any
 
 from chromadb.config import Settings
-from langchain.vectorstores import Chroma
 from pilot.logs import logger
 from pilot.vector_store.base import VectorStoreBase
 
@@ -11,6 +10,8 @@ class ChromaStore(VectorStoreBase):
     """chroma database"""
 
     def __init__(self, ctx: {}) -> None:
+        from langchain.vectorstores import Chroma
+
         self.ctx = ctx
         self.embeddings = ctx.get("embeddings", None)
         self.persist_dir = os.path.join(
diff --git a/pilot/vector_store/milvus_store.py b/pilot/vector_store/milvus_store.py
index 9b95f4683..0f1ac7e26 100644
--- a/pilot/vector_store/milvus_store.py
+++ b/pilot/vector_store/milvus_store.py
@@ -1,6 +1,7 @@
+from __future__ import annotations
+
 from typing import Any, Iterable, List, Optional, Tuple
 
-from langchain.docstore.document import Document
 from pymilvus import Collection, DataType, connections, utility
 
 from pilot.logs import logger
@@ -279,7 +280,9 @@ class MilvusStore(VectorStoreBase):
         round_decimal: int = -1,
         timeout: Optional[int] = None,
         **kwargs: Any,
-    ) -> Tuple[List[float], List[Tuple[Document, Any, Any]]]:
+    ):
+        from langchain.docstore.document import Document
+
         self.col.load()
         # use default index params.
         if param is None: