feat: modify _set_python_path location to command.py from utils.py

Signed-off-by: ImMin5 <[email protected]>
(cherry picked from commit 4e07f73)

Author: ImMin5

src/spaceone/core/command.py

@@ -1,9 +1,11 @@
 import os
 import shutil
+import sys
 import unittest
 from typing import List
 
 import click
+import pkg_resources
 
 from spaceone.core import config, pygrpc, fastapi, utils
 from spaceone.core import scheduler as scheduler_v1
@@ -105,9 +107,30 @@ def test(config_file=None, dir=None, failfast=False, scenario: str = None, param
     RichTestRunner(verbosity=verbose, failfast=failfast).run(full_suite)
 
 
+def _set_python_path(package, module_path):
+    current_path = os.getcwd()
+
+    if current_path not in sys.path:
+        sys.path.insert(0, current_path)
+
+    if isinstance(module_path, tuple):
+        for path in module_path:
+            if path not in sys.path:
+                sys.path.insert(0, path)
+
+    if '.' in package:
+        pkg_resources.declare_namespace(package)
+
+    try:
+        __import__(package)
+    except Exception:
+        raise Exception(f'The package({package}) can not imported. '
+                        'Please check the module path.')
+
+
 def _set_server_config(package, module_path=None, port=None, config_file=None):
     # 1. Set a python path
-    utils.set_python_path(package, module_path)
+    _set_python_path(package, module_path)
 
     # 2. Initialize config from command argument
     config.init_conf(

src/spaceone/core/config/default_conf.py

@@ -24,7 +24,6 @@
 REST_TITLE = ''
 REST_DESCRIPTION = ''
 REST_CONTACT = {}
-REST_MAX_THREAD_POOL = 40
 
 # REST Middlewares
 REST_MIDDLEWARES = []

src/spaceone/core/fastapi/server.py

@@ -1,7 +1,6 @@
 import logging
 
 import uvicorn
-from anyio import to_thread
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
 
@@ -122,8 +121,6 @@ def _add_middlewares(app):
 def _init_fast_api():
     global_conf = config.get_global()
     server_info = ServerInfoManager()
-    # set thread pool size
-    to_thread.current_default_thread_limiter().total_tokens = global_conf.get('REST_MAX_THREAD_POOL', 40)
 
     return FastAPI(
         title=global_conf.get('REST_TITLE', 'Document'),

src/spaceone/core/utils.py

@@ -498,26 +498,5 @@ def change_dict_with_dot_notation(dict_value: dict, key='', dots=None) -> dict:
     return dots
 
 
-def set_python_path(package, module_path):
-    current_path = os.getcwd()
-
-    if current_path not in sys.path:
-        sys.path.insert(0, current_path)
-
-    if isinstance(module_path, tuple):
-        for path in module_path:
-            if path not in sys.path:
-                sys.path.insert(0, path)
-
-    if '.' in package:
-        pkg_resources.declare_namespace(package)
-
-    try:
-        __import__(package)
-    except Exception:
-        raise Exception(f'The package({package}) can not imported. '
-                        'Please check the module path.')
-
-
 if __name__ == '__main__':
     pass