diff --git a/csst_dfs_api_cluster/facility/level1.py b/csst_dfs_api_cluster/facility/level1.py index 8f02375eb9b9db12283e2a4fc6a8d141c2394a19..301598f15bd3c9ed55d73d91461639598f57d54a 100644 --- a/csst_dfs_api_cluster/facility/level1.py +++ b/csst_dfs_api_cluster/facility/level1.py @@ -216,7 +216,7 @@ class Level1DataApi(object): prc_time : [str] pipeline_id : [str] pmapname : [str] - build_id : [int] + build : [int] return csst_dfs_common.models.Result ''' @@ -234,7 +234,7 @@ class Level1DataApi(object): prc_status = get_parameter(kwargs, "prc_status", 0), prc_time = get_parameter(kwargs, "prc_time", format_datetime(datetime.now())), pipeline_id = get_parameter(kwargs, "pipeline_id", ""), - build_id = get_parameter(kwargs, "build_id", 0), + build = get_parameter(kwargs, "build", 0), pmapname = get_parameter(kwargs, "pmapname", ""), refs = get_parameter(kwargs, "refs", {}) ) diff --git a/csst_dfs_api_cluster/facility/level2.py b/csst_dfs_api_cluster/facility/level2.py index 9bcd8148ff93d2f316cdf8546703bfa4c6551e29..4bff9b63c47f90def1ac7d0e5620f0409ef2904c 100644 --- a/csst_dfs_api_cluster/facility/level2.py +++ b/csst_dfs_api_cluster/facility/level2.py @@ -35,7 +35,7 @@ class Level2DataApi(object): prc_status : [int], import_status : [int], filename: [str], - build_id : [int], + build : [int], pipeline_id: [str], limit: limits returns the number of records,default 0:no-limit @@ -57,7 +57,7 @@ class Level2DataApi(object): object_name = get_parameter(kwargs, "object_name"), limit = get_parameter(kwargs, "limit", 0), pipeline_id = get_parameter(kwargs, "pipeline_id",""), - build_id = get_parameter(kwargs, "build_id", -1024), + build = get_parameter(kwargs, "build", -1024), other_conditions = {"test":"cnlab.test"} ),metadata = get_auth_headers()) @@ -243,7 +243,7 @@ class Level2DataApi(object): prc_status : [int] prc_time : [str] pipeline_id : [str] - build_id : [int] + build : [int] return csst_dfs_common.models.Result ''' @@ -261,7 +261,7 @@ class Level2DataApi(object): qc2_status = get_parameter(kwargs, "qc2_status", 0), prc_status = get_parameter(kwargs, "prc_status", 0), prc_time = get_parameter(kwargs, "prc_time", format_datetime(datetime.now())), - build_id = get_parameter(kwargs, "build_id", 0), + build = get_parameter(kwargs, "build", 0), pipeline_id = get_parameter(kwargs, "pipeline_id", "") ) def stream(rec):