Commit 2e71db35 authored by Wei Shoulin's avatar Wei Shoulin
Browse files

add default

parent 921475db
...@@ -201,16 +201,16 @@ class Level1DataApi(object): ...@@ -201,16 +201,16 @@ class Level1DataApi(object):
rec = level1_pb2.Level1Record( rec = level1_pb2.Level1Record(
id = 0, id = 0,
level0_id = get_parameter(kwargs, "level0_id"), level0_id = get_parameter(kwargs, "level0_id", ""),
module_id = get_parameter(kwargs, "module_id", ''), module_id = get_parameter(kwargs, "module_id", ""),
data_type = get_parameter(kwargs, "data_type"), data_type = get_parameter(kwargs, "data_type", ""),
cor_sci_id = get_parameter(kwargs, "cor_sci_id"), cor_sci_id = get_parameter(kwargs, "cor_sci_id", 0),
prc_params = get_parameter(kwargs, "prc_params"), prc_params = get_parameter(kwargs, "prc_params", ""),
filename = get_parameter(kwargs, "filename", ""), filename = get_parameter(kwargs, "filename", ""),
file_path = get_parameter(kwargs, "file_path", ""), file_path = get_parameter(kwargs, "file_path", ""),
prc_status = get_parameter(kwargs, "prc_status", -1), prc_status = get_parameter(kwargs, "prc_status", -1),
prc_time = get_parameter(kwargs, "prc_time", format_datetime(datetime.now())), prc_time = get_parameter(kwargs, "prc_time", format_datetime(datetime.now())),
pipeline_id = get_parameter(kwargs, "pipeline_id"), pipeline_id = get_parameter(kwargs, "pipeline_id", ""),
refs = get_parameter(kwargs, "refs", {}) refs = get_parameter(kwargs, "refs", {})
) )
def stream(rec): def stream(rec):
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment