From 97a43e705636f2214ebcdd8021ede1677e880d94 Mon Sep 17 00:00:00 2001 From: harshits Date: Fri, 17 Jan 2020 13:28:34 +0530 Subject: [PATCH] Adding changes --- qds_sdk/quest.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/qds_sdk/quest.py b/qds_sdk/quest.py index 80c456ad..7d2d7201 100644 --- a/qds_sdk/quest.py +++ b/qds_sdk/quest.py @@ -750,7 +750,7 @@ def create_pipeline(pipeline_name, schema, source_data_format, source_data_store 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", None), + window_interval_frequency=operator["windowed_group"].get("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]")