status-1

csst_dfs_api_cluster/facility/calmerge.py

@@ -122,7 +122,6 @@ class CalMergeApi(object):
         ''' insert a calibration merge record into database
  
         parameter kwargs:
-            id : [int]
             detector_no : [str]
             ref_type : [str]
             obs_time : [str]
@@ -143,7 +142,7 @@ class CalMergeApi(object):
             exp_time = get_parameter(kwargs, "exp_time"),
             filename = get_parameter(kwargs, "filename"),
             file_path = get_parameter(kwargs, "file_path"),
-            prc_status = get_parameter(kwargs, "prc_status"),
+            prc_status = get_parameter(kwargs, "prc_status",-1),
             prc_time = get_parameter(kwargs, "prc_time"),
             level0_ids = get_parameter(kwargs, "level0_ids", [])
         )

csst_dfs_api_cluster/facility/level0prc.py

@@ -85,7 +85,7 @@ class Level0PrcApi(object):
             pipeline_id = get_parameter(kwargs, "pipeline_id"),
             prc_module = get_parameter(kwargs, "prc_module"),
             params_id = get_parameter(kwargs, "params_id"),
-            prc_status = get_parameter(kwargs, "prc_status"),
+            prc_status = get_parameter(kwargs, "prc_status", -1),
             prc_time = get_parameter(kwargs, "prc_time"),
             file_path = get_parameter(kwargs, "file_path")
         )

csst_dfs_api_cluster/ifs/level1.py

 import grpc
+import datetime
 
 from csst_dfs_commons.models import Result
 from csst_dfs_commons.models.common import from_proto_model_list
@@ -155,8 +156,8 @@ class Level1DataApi(object):
             sky_id = get_parameter(kwargs, "sky_id"),
             filename = get_parameter(kwargs, "filename"),
             file_path = get_parameter(kwargs, "file_path"),
-            prc_status = get_parameter(kwargs, "prc_status"),
-            prc_time = get_parameter(kwargs, "prc_time"),
+            prc_status = get_parameter(kwargs, "prc_status", -1),
+            prc_time = get_parameter(kwargs, "prc_time", format_datetime(datetime.datetime.now())),
             pipeline_id = get_parameter(kwargs, "pipeline_id")
         )
         req = level1_pb2.WriteLevel1Req(record = rec)

csst_dfs_api_cluster/msc/level1.py

 import grpc
+import datetime
 
 from csst_dfs_commons.models import Result
 from csst_dfs_commons.models.common import from_proto_model_list
@@ -149,8 +150,8 @@ class Level1DataApi(object):
             bias_id = get_parameter(kwargs, "bias_id"),
             filename = get_parameter(kwargs, "filename"),
             file_path = get_parameter(kwargs, "file_path"),
-            prc_status = get_parameter(kwargs, "prc_status"),
-            prc_time = get_parameter(kwargs, "prc_time"),
+            prc_status = get_parameter(kwargs, "prc_status", -1),
+            prc_time = get_parameter(kwargs, "prc_time", format_datetime(datetime.datetime.now())),
             pipeline_id = get_parameter(kwargs, "pipeline_id")
         )
         req = level1_pb2.WriteLevel1Req(record = rec)