diff --git a/qds_sdk/quest.py b/qds_sdk/quest.py
index 7d2d7201..65ae8acf 100644
--- 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, topic_type,
+    def create_pipeline(pipeline_name, schema, source_data_format, source_data_store, sink_data_store,
                         checkpoint_location,
                         cluster_label,
                         output_mode,
@@ -612,6 +612,7 @@ def create_pipeline(pipeline_name, schema, source_data_format, source_data_store
                         sink_topics=None,
                         trigger_interval=None,
                         can_retry=True,
+                        topic_type="multiple",
                         command_line_options=None,
                         operators=None,
                         channel_id=None,