fix: salesforce query offset removed

Multiwoven · Apr 17, 2024 · b5f3862 · b5f3862
1 parent d802fa8
commit b5f3862
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/integrations/Gemfile.lock b/integrations/Gemfile.lock
@@ -7,7 +7,7 @@ GIT
 PATH
   remote: .
   specs:
-    multiwoven-integrations (0.1.61)
+    multiwoven-integrations (0.1.62)
       activesupport
       async-websocket
       csv

diff --git a/integrations/lib/multiwoven/integrations/rollout.rb b/integrations/lib/multiwoven/integrations/rollout.rb
@@ -2,7 +2,7 @@
 
 module Multiwoven
   module Integrations
-    VERSION = "0.1.61"
+    VERSION = "0.1.62"
 
     ENABLED_SOURCES = %w[
       Snowflake

diff --git a/integrations/lib/multiwoven/integrations/source/salesforce_consumer_goods_cloud/client.rb b/integrations/lib/multiwoven/integrations/source/salesforce_consumer_goods_cloud/client.rb
@@ -41,7 +41,7 @@ def read(sync_config)
             connection_config = sync_config.source.connection_specification.with_indifferent_access
             initialize_client(connection_config)
             query = sync_config.model.query
-            query = batched_query(query, sync_config.limit, sync_config.offset) unless sync_config.limit.nil? && sync_config.offset.nil?
+            query = "#{query} LIMIT #{sync_config.limit}" unless sync_config.limit.nil?
             queried_data = @client.query(query)
             results = queried_data.map do |record|
               flatten_nested_hash(record)