Adding changes

dreamerHarshit · Jan 17, 2020 · 58da3b4 · 58da3b4
1 parent 625d57e
commit 58da3b4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/qds_sdk/quest.py b/qds_sdk/quest.py
@@ -744,7 +744,7 @@ def create_pipeline(pipeline_name, schema, source_data_format, source_data_store
                                                                    select_column_names=operator["select"]["column_names"])
                 elif operator.items()[0][0] is "watermark":
                     operator_response = QuestAssisted.add_operator(pipeline_id, operator="watermark",
-                                                                   watermark_column_name=operator["watermark"]["column_names"],
+                                                                   watermark_column_name=operator["watermark"]["column_name"],
                                                                    watermark_frequency=operator["watermark"]["frequency"])
 
                 elif operator.items()[0][0] is "windowed_group":