Update interpolate query (#799)

Signed-off-by: GBBBAS <[email protected]>
rtdip · Aug 9, 2024 · 5a04ecc · 5a04ecc
1 parent cbe4648
commit 5a04ecc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/api/v1/common.py b/src/api/v1/common.py
@@ -246,7 +246,7 @@ def convert_value(x):
                 return float(x)
             return x
 
-        data_parsed = data.replace({np.nan: None}).map(convert_value)
+        data_parsed = data.map(convert_value).replace({np.nan: None})
         schema = build_table_schema(data_parsed, index=False, primary_key=False)
         data_dict = data_parsed.to_dict(orient="records")
 

diff --git a/src/sdk/python/rtdip_sdk/queries/time_series/_time_series_query_builder.py b/src/sdk/python/rtdip_sdk/queries/time_series/_time_series_query_builder.py
@@ -1026,7 +1026,7 @@ def _query_builder(parameters_dict: dict, query_type: str) -> str:
             parameters_dict
         )
         sample_parameters["is_resample"] = False
-        sample_parameters["to_json"] = to_json
+        parameters_dict["to_json"] = to_json
         return _interpolation_query(parameters_dict, sample_query, sample_parameters)
 
     if query_type == "time_weighted_average":