Adding test for kinesis to s3

dreamerHarshit · Jan 17, 2020 · 87a571d · 87a571d
1 parent 610844a
commit 87a571d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/qds_sdk/quest.py b/qds_sdk/quest.py
@@ -603,7 +603,7 @@ def add_sink(pipeline_id, data_store,
         raise ParseError("Please add only one valid sink out of [kafka, s3, snowflake, hive, google_storage]")
 
     @staticmethod
-    def create_pipeline(pipeline_name, schema, source_data_format, source_data_store, sink_data_store,
+    def create_pipeline(pipeline_name, schema, source_data_format, source_data_store, sink_data_store, topic_type,
                         checkpoint_location,
                         cluster_label,
                         output_mode,
@@ -619,7 +619,7 @@ def create_pipeline(pipeline_name, schema, source_data_format, source_data_store
                         stream_name=None,
                         starting_position=None,
                         other_kinesis_settings=None,
-                        broker=None, topic_type=None,
+                        broker=None,
                         use_registry=None,
                         registry_subject=None,
                         registry_id=None,