This is an automated email from the ASF dual-hosted git repository. skperez pushed a commit to branch SDAP-397 in repository https://gitbox.apache.org/repos/asf/incubator-sdap-nexus.git
commit 0f557e08e586c69f9992555226982c634702d12a Author: skorper <[email protected]> AuthorDate: Wed Jul 20 00:09:54 2022 -0700 Added unit field to matchup response. Unit field is currently null --- analysis/webservice/algorithms_spark/Matchup.py | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/analysis/webservice/algorithms_spark/Matchup.py b/analysis/webservice/algorithms_spark/Matchup.py index d6d850f..85f3ab0 100644 --- a/analysis/webservice/algorithms_spark/Matchup.py +++ b/analysis/webservice/algorithms_spark/Matchup.py @@ -14,7 +14,7 @@ # limitations under the License. - +from typing import Optional import json import logging import threading @@ -326,10 +326,13 @@ class DataPoint: exist in the source data file. :attribute variable_value: value at some point for the given variable. + :attribute variable_unit: Unit of the measurement. Will be None if + no unit is known. """ variable_name: str = None cf_variable_name: str = None variable_value: float = None + variable_unit: Optional[str] = None class DomsPoint(object): @@ -387,7 +390,8 @@ class DomsPoint(object): data.append(DataPoint( variable_name=variable.variable_name, variable_value=data_val, - cf_variable_name=variable.standard_name + cf_variable_name=variable.standard_name, + variable_unit=None )) point.data = data @@ -500,7 +504,8 @@ class DomsPoint(object): if val: data.append(DataPoint( variable_name=name, - variable_value=val + variable_value=val, + variable_unit=None )) @@ -510,7 +515,8 @@ class DomsPoint(object): data.extend([DataPoint( variable_name=variable.variable_name, variable_value=var_value, - cf_variable_name=variable.standard_name + cf_variable_name=variable.standard_name, + variable_unit=None ) for var_value, variable in zip( edge_point['var_values'], edge_point['variables']
