Adding changes

dreamerHarshit · Jan 17, 2020 · 54e15ab · 54e15ab
1 parent 46aa5e6
commit 54e15ab
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/qds_sdk/quest.py b/qds_sdk/quest.py
@@ -750,8 +750,8 @@ def create_pipeline(pipeline_name, schema, source_data_format, source_data_store
                 elif operator.items()[0][0] is "windowed_group":
                     operator_response = QuestAssisted.add_operator(pipeline_id, operator="windowed_group",
                                                                    groupby_column_name=operator["windowed_group"]["column_name"],
-                                                                   sliding_window_value=operator["windowed_group"]["sliding_window_value"],
-                                                                   window_interval_frequency=operator["windowed_group"].get("window_interval_frequency"),
+                                                                   sliding_window_value=operator["windowed_group"].get("sliding_window_value"),
+                                                                   window_interval_frequency=operator["windowed_group"]["window_interval_frequency"],
                                                                    other_columns=operator["windowed_group"]["other_columns"])
                 else:
                     raise ParseError("Please enter valid operator value. Valid values are [filter, select, watermark, windowed_group]")
@@ -863,10 +863,10 @@ def _window_group_operator(url, column_name, sliding_window_value, window_interv
                                             {"column_name": column_name,
                                              "sliding_window_value": {
                                                  "frequency": sliding_window_value,
-                                                 "unit": "minute"},
+                                                 "unit": "minutes"},
                                              "window_interval": {
                                                  "frequency": window_interval_frequency,
-                                                 "unit": "minute"}},
+                                                 "unit": "minutes"}},
                                         "other_columns": other_columns,
                                         "action": "count"}}}
         return conn.put(url, data)