Use python -m to start script

Author: sitaowang1998

components/clp-package-utils/clp_package_utils/scripts/native/archive_manager.py

@@ -28,6 +28,7 @@
     END_TS_ARG,
     FIND_COMMAND,
 )
+
 from .utils import validate_dataset_exists
 
 logger: logging.Logger = logging.getLogger(__file__)

components/clp-package-utils/clp_package_utils/scripts/native/decompress.py

@@ -31,6 +31,7 @@
     get_clp_home,
     load_config_file,
 )
+
 from .utils import (
     run_function_in_process,
     submit_query_job,

components/clp-package-utils/clp_package_utils/scripts/native/search.py

@@ -24,6 +24,7 @@
     get_clp_home,
     load_config_file,
 )
+
 from .utils import (
     run_function_in_process,
     submit_query_job,

components/clp-py-utils/clp_py_utils/create-db-tables.py

@@ -32,11 +32,9 @@ def main(argv):
     config_file_path = pathlib.Path(parsed_args.config)
     storage_engine = StorageEngine(parsed_args.storage_engine)
 
-    script_dir = pathlib.Path(__file__).parent.resolve()
-
     # fmt: off
     cmd = [
-        "python3", str(script_dir / "initialize-clp-metadata-db.py"),
+        "python3", "-m", "clp_py_utils.initialize-clp-metadata-db",
         "--config", str(config_file_path),
         "--storage-engine", str(storage_engine),
     ]
@@ -45,7 +43,7 @@ def main(argv):
 
     # fmt: off
     cmd = [
-        "python3", str(script_dir / "initialize-orchestration-db.py"),
+        "python3", "-m", "clp_py_utils.initialize-orchestration-db",
         "--config", str(config_file_path),
     ]
     # fmt: on

components/job-orchestration/job_orchestration/executor/compress/spider_compress.py

@@ -3,9 +3,10 @@
 from clp_py_utils.clp_logging import get_logger
 from spider_py import Int8, Int64, TaskContext
 
-from .compression_task import compression_entry_point
 from job_orchestration.utils.spider_utils import int8_list_to_utf8_str, utf8_str_to_int8_list
 
+from .compression_task import compression_entry_point
+
 # Setup logging
 logger = get_logger("spider_compression")
 

components/job-orchestration/job_orchestration/garbage_collector/archive_garbage_collector.py

@@ -18,6 +18,8 @@
 )
 from clp_py_utils.sql_adapter import SqlAdapter
 
+from job_orchestration.scheduler.constants import QueryJobStatus
+
 from .constants import (
     ARCHIVE_GARBAGE_COLLECTOR_NAME,
     MIN_TO_SECONDS,
@@ -29,7 +31,6 @@
     execute_deletion,
     validate_storage_type,
 )
-from job_orchestration.scheduler.constants import QueryJobStatus
 
 logger = get_logger(ARCHIVE_GARBAGE_COLLECTOR_NAME)