chore(CE): Allow Batch Support and Batch Size for S3 (#941)

* Resolve conflict in cherry-pick of cb46584b60b87b9408cb5dcdc84133d956aa844d and change the commit message

* chore(CE): Resolved conflict

---------

Co-authored-by: TivonB-AI2 <124182151+TivonB-AI2@users.noreply.github.com>
Co-authored-by: TivonB-AI2 <tivon.brown@squared.ai>

Author: aisquared-ci-bot[bot]

integrations/Gemfile.lock

@@ -7,7 +7,7 @@ GIT
 PATH
   remote: .
   specs:
-    multiwoven-integrations (0.34.17)
+    multiwoven-integrations (0.34.18)
       MailchimpMarketing
       activesupport
       async-websocket

integrations/lib/multiwoven/integrations/destination/amazon_s3/client.rb

@@ -154,7 +154,9 @@ def create_streams(tables)
           Multiwoven::Integrations::Protocol::Stream.new(
             name: r[:tablename],
             action: StreamAction["create"],
-            json_schema: convert_to_json_schema(r[:columns])
+            json_schema: convert_to_json_schema(r[:columns]),
+            batch_support: true,
+            batch_size: 100_000
           )
         end
       end

integrations/lib/multiwoven/integrations/rollout.rb

@@ -2,7 +2,7 @@
 
 module Multiwoven
   module Integrations
-    VERSION = "0.34.17"
+    VERSION = "0.34.18"
 
     ENABLED_SOURCES = %w[
       Snowflake

integrations/spec/multiwoven/integrations/destination/amazon_s3/client_spec.rb

@@ -135,8 +135,8 @@
       expect(catalog.streams.count).to eql(1)
       expect(catalog.schema_mode).to eql("schema")
       expect(catalog.streams[0].name).to eql("test_file")
-      expect(catalog.streams[0].batch_support).to eql(false)
-      expect(catalog.streams[0].batch_size).to eql(1)
+      expect(catalog.streams[0].batch_support).to eql(true)
+      expect(catalog.streams[0].batch_size).to eql(100_000)
       expect(catalog.streams[0].supported_sync_modes).to eql(%w[incremental])
     end
 
@@ -176,8 +176,8 @@
         expect(message.catalog.streams.count).to eql(1)
         expect(message.catalog.schema_mode).to eql("schema")
         expect(message.catalog.streams[0].name).to eql("test_file")
-        expect(message.catalog.streams[0].batch_support).to eql(false)
-        expect(message.catalog.streams[0].batch_size).to eql(1)
+        expect(message.catalog.streams[0].batch_support).to eql(true)
+        expect(message.catalog.streams[0].batch_size).to eql(100_000)
         expect(message.catalog.streams[0].supported_sync_modes).to eql(%w[incremental])
       end
     end