* after pre-commit

Author: HYLcool

trinity/cli/launcher.py

@@ -10,9 +10,13 @@
 
 from trinity.common.config import Config, load_config
 from trinity.common.constants import DataProcessorPipelineType
+from trinity.data.utils import (
+    activate_data_processor,
+    stop_data_processor,
+    validate_data_pipeline,
+)
 from trinity.explorer.explorer import Explorer
 from trinity.trainer.trainer import Trainer
-from trinity.data.utils import activate_data_processor, stop_data_processor, validate_data_pipeline
 from trinity.utils.log import get_logger
 from trinity.utils.plugin_loader import load_plugins
 
@@ -148,6 +152,7 @@ def both(config: Config) -> None:
     explorer.shutdown.remote()
     trainer.shutdown.remote()
 
+
 def run(config_path: str, dlc: bool = False, plugin_dir: str = None):
     load_plugins(plugin_dir)
     config = load_config(config_path)

trinity/data/utils.py

@@ -1,10 +1,10 @@
 from trinity.common.config import DataPipelineConfig
 from trinity.common.constants import DataProcessorPipelineType
-
 from trinity.utils.log import get_logger
 
 logger = get_logger(__name__)
 
+
 def activate_data_processor(data_processor_url: str, config_path: str):
     """Check whether to activate data module and preprocess datasets."""
     from trinity.cli.client import request
@@ -18,6 +18,7 @@ def activate_data_processor(data_processor_url: str, config_path: str):
         logger.error(f"Failed to activate data module: {res['return_msg']}.")
         return
 
+
 def stop_data_processor(base_data_processor_url: str):
     """Stop all pipelines in the data processor"""
     from trinity.cli.client import request
@@ -28,6 +29,7 @@ def stop_data_processor(base_data_processor_url: str):
         logger.error(f"Failed to stop all data pipelines: {res['return_msg']}.")
         return
 
+
 def validate_data_pipeline(
     data_pipeline_config: DataPipelineConfig, pipeline_type: DataProcessorPipelineType
 ):