Skip to content

Commit 9922b55

Browse files
authored
Remove window_size_mins parameter from TWA (#901)
* remove window_size_mins parameter from TWA Signed-off-by: cching95 <chloe.ching@shell.com> * add default value as metadata for step if not provided Signed-off-by: cching95 <chloe.ching@shell.com> --------- Signed-off-by: cching95 <chloe.ching@shell.com>
1 parent 4a36743 commit 9922b55

4 files changed

Lines changed: 4 additions & 28 deletions

File tree

src/api/v1/models.py

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -486,24 +486,17 @@ def __init__(
486486
class TimeWeightedAverageQueryParams:
487487
def __init__(
488488
self,
489-
window_size_mins: int = Query(
490-
None,
491-
description="window_size_mins is deprecated and will be removed in v1.0.0. Please use time_interval_rate and time_interval_unit instead.",
492-
examples=[20],
493-
deprecated=True,
494-
),
495489
time_interval_rate: str = DuplicatedQueryParameters.time_interval_rate,
496490
time_interval_unit: str = DuplicatedQueryParameters.time_interval_unit,
497491
window_length: int = Query(
498492
..., description="Window Length in days", examples=[1]
499493
),
500494
step: str = Query(
501-
...,
495+
default="metadata",
502496
description='Step can be "true", "false" or "metadata". "metadata" will retrieve the step value from the metadata table.',
503497
examples=["true", "false", "metadata"],
504498
),
505499
):
506-
self.window_size_mins = window_size_mins
507500
self.time_interval_rate = time_interval_rate
508501
self.time_interval_unit = time_interval_unit
509502
self.window_length = window_length

src/sdk/python/rtdip_sdk/queries/time_series/time_weighted_average.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
# limitations under the License.
1414
import logging
1515
import pandas as pd
16+
1617
from ._time_series_query_builder import _query_builder
1718

1819

@@ -37,7 +38,6 @@ def get(connection: object, parameters_dict: dict) -> pd.DataFrame:
3738
tag_names (list): List of tagname or tagnames
3839
start_date (str): Start date (Either a utc date in the format YYYY-MM-DD or a utc datetime in the format YYYY-MM-DDTHH:MM:SS or specify the timezone offset in the format YYYY-MM-DDTHH:MM:SS+zz:zz)
3940
end_date (str): End date (Either a utc date in the format YYYY-MM-DD or a utc datetime in the format YYYY-MM-DDTHH:MM:SS or specify the timezone offset in the format YYYY-MM-DDTHH:MM:SS+zz:zz)
40-
window_size_mins (int): (deprecated) Window size in minutes. Please use time_interval_rate and time_interval_unit below instead.
4141
time_interval_rate (str): The time interval rate (numeric input)
4242
time_interval_unit (str): The time interval unit (second, minute, day, hour)
4343
window_length (int): Add longer window time in days for the start or end of specified date to cater for edge cases.
@@ -65,12 +65,8 @@ def get(connection: object, parameters_dict: dict) -> pd.DataFrame:
6565
if parameters_dict["pivot"] is True and parameters_dict["display_uom"] is True:
6666
raise ValueError("pivot True and display_uom True cannot be used together")
6767

68-
if "window_size_mins" in parameters_dict:
69-
logging.warning(
70-
"Parameter window_size_mins is deprecated and will be removed in v1.0.0. Please use time_interval_rate and time_interval_unit instead."
71-
)
72-
parameters_dict["time_interval_rate"] = str(parameters_dict["window_size_mins"])
73-
parameters_dict["time_interval_unit"] = "minute"
68+
if "step" not in parameters_dict: # default step to metadata if not provided
69+
parameters_dict["step"] = "metadata"
7470

7571
try:
7672
query = _query_builder(parameters_dict, "time_weighted_average")

tests/api/v1/api_test_objects.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -152,12 +152,10 @@
152152
RAW_MOCKED_PARAMETER_ERROR_DICT.copy()
153153
)
154154

155-
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_DICT["window_size_mins"] = "15"
156155
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_DICT["time_interval_rate"] = "15"
157156
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_DICT["time_interval_unit"] = "minute"
158157
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_DICT["window_length"] = 10
159158
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_DICT["step"] = "metadata"
160-
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_ERROR_DICT["window_size_mins"] = "15"
161159
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_ERROR_DICT["time_interval_rate"] = "15"
162160
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_ERROR_DICT["time_interval_unit"] = "minute"
163161
TIME_WEIGHTED_AVERAGE_MOCKED_PARAMETER_ERROR_DICT["window_length"] = 10

tests/sdk/python/rtdip_sdk/queries/time_series/test_time_weighted_average.py

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -60,18 +60,7 @@ def test_time_weighted_average_check_tags(mocker: MockerFixture):
6060
TWA_MOCKED_QUERY_CHECK_TAGS,
6161
time_weighted_average_get,
6262
)
63-
64-
65-
def test_time_weighted_average_with_window_size_mins(mocker: MockerFixture):
6663
MOCKED_TWA_PARAMETER_DICT["case_insensitivity_tag_search"] = False
67-
MOCKED_TWA_PARAMETER_DICT["window_size_mins"] = 15
68-
69-
_test_base_succeed(
70-
mocker,
71-
MOCKED_TWA_PARAMETER_DICT,
72-
TWA_MOCKED_QUERY,
73-
time_weighted_average_get,
74-
)
7564

7665

7766
def test_time_weighted_average_metadata_step(mocker: MockerFixture):

0 commit comments

Comments
 (0)