Skip to content

Commit

Permalink
Adding changes
Browse files Browse the repository at this point in the history
  • Loading branch information
harshits committed Jan 17, 2020
1 parent a53129b commit 97a43e7
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion qds_sdk/quest.py
Original file line number Diff line number Diff line change
Expand Up @@ -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]")
Expand Down

0 comments on commit 97a43e7

Please sign in to comment.