Export members in batches during sync process

GetUp · Feb 19, 2025 · ac4bff7 · ac4bff7
1 parent e9fa7c4
commit ac4bff7
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/lib/identity_tijuana.rb b/lib/identity_tijuana.rb
@@ -106,11 +106,13 @@ def self.fetch_user_updates_impl(sync_id)
       )
     ).pluck('member_id')
 
-    updated_members = Member.includes(:phone_numbers, :addresses, :member_subscriptions)
-                            .where(id: updated_member_ids)
+    updated_member_ids.each_slice(Settings.tijuana.pull_batch_amount) do |batch_ids|
+      updated_members = Member.includes(:phone_numbers, :addresses, :member_subscriptions)
+                              .where(id: batch_ids)
 
-    updated_members.each do |member|
-      MemberSync.export_member(member, sync_id)
+      updated_members.each do |member|
+        MemberSync.export_member(member, sync_id)
+      end
     end
 
     unless updated_users.empty?