diff --git a/integrations/Gemfile.lock b/integrations/Gemfile.lock
index 0220dbbc..222fa309 100644
--- 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
index 993520ac..c8b696cb 100644
--- 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
index 3b771a6d..ce2ad9b8 100644
--- 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)