msg proc

csst_dfs_client/level0.py

@@ -75,7 +75,10 @@ def find(project_id: Optional[str] = None,
     
     if obs_time is not None:
         params['obs_time_start'], params['obs_time_end'] = obs_time
-        utils.is_valid_datetime_format(params['obs_time_start']) or not utils.is_valid_datetime_format(params['obs_time_end'])
+        if params['obs_time_start'] and utils.is_valid_datetime_format(params['obs_time_start']):
+            pass
+        if params['obs_time_end'] and utils.is_valid_datetime_format(params['obs_time_end']):
+            pass 
     if create_time is not None:
         params['create_time_start'], params['create_time_end'] = create_time
         utils.is_valid_datetime_format(params['create_time_start']) or utils.is_valid_datetime_format(params['create_time_end'])
@@ -176,9 +179,8 @@ def write_cat(local_file: str,
 def generate_prc_msg(module_id: Literal['MSC', 'IFS', 'MCI', 'HSTDM', 'CPIC'], 
                     obs_id: str, 
                     detector_no: str,
-                    batch_id: str = constants.DEFAULT_BATCH_ID,
                     dataset: str = constants.DEFAULT_DATASET,
-                    pipeline_id: str = '') -> Result:
+                    batch_id: str = constants.DEFAULT_BATCH_ID) -> Result:
     """
     生成流水线的处理消息
     
@@ -186,7 +188,6 @@ def generate_prc_msg(module_id: Literal['MSC', 'IFS', 'MCI', 'HSTDM', 'CPIC'],
         module_id (str): 模块ID
         obs_id (str): 观测ID
         detector_no (str): 探测器编号
-        pipeline_id (str): 流水管线ID，默认为空字符串
         dataset (Optional[str], optional): 数据集名称..
         batch_id (Optional[str], optional): 批次ID. Defaults to 'auto'.
     
@@ -197,7 +198,6 @@ def generate_prc_msg(module_id: Literal['MSC', 'IFS', 'MCI', 'HSTDM', 'CPIC'],
     params = {
         'dataset': dataset,
         'batch_id': batch_id,
-        'pipeline_id': pipeline_id,
         'obs_id': obs_id,
         'detector_no': detector_no,
     }

csst_dfs_client/level1.py

@@ -209,7 +209,6 @@ def write(local_file: Union[IO, str],
 
 def generate_prc_msg(module_id: Literal['MSC', 'IFS', 'MCI', 'HSTDM', 'CPIC'], 
                     level1_id: str, 
-                    pipeline_id: Optional[str] = '',
                     dataset: str = constants.DEFAULT_DATASET,
                     batch_id: str = constants.DEFAULT_BATCH_ID) -> Result:
     """
@@ -229,7 +228,6 @@ def generate_prc_msg(module_id: Literal['MSC', 'IFS', 'MCI', 'HSTDM', 'CPIC'],
     params = {
         'dataset': dataset,
         'batch_id': batch_id,
-        'pipeline_id': pipeline_id,
         'level1_id': level1_id,
     }