From 53e361fa8d7c244951b4d0567cf604b0ec73960c Mon Sep 17 00:00:00 2001
From: Holger Brunn <mail@hunki-enterprises.com>
Date: Mon, 9 Mar 2026 14:17:08 +0100
Subject: [PATCH] [IMP] openupgrade.chunked: support v19

---
 openupgradelib/openupgrade.py |  5 ++++-
 tests/test_openupgradelib.py  | 13 +++++++++++++
 2 files changed, 17 insertions(+), 1 deletion(-)

diff --git a/openupgradelib/openupgrade.py b/openupgradelib/openupgrade.py
index 00a50155..80ba6b15 100644
--- a/openupgradelib/openupgrade.py
+++ b/openupgradelib/openupgrade.py
@@ -3587,7 +3587,10 @@ def chunked(records, single=True):
     """Memory and performance friendly method to iterate over a potentially
     large number of records. Yields either a whole chunk or a single record
     at the time. Don't nest calls to this method."""
-    size = core.models.PREFETCH_MAX
+    # PREFETCH_MAX lives in models in <v19, and tools.constants afterwards
+    size = (
+        getattr(core.models, "PREFETCH_MAX", None) or core.tools.constants.PREFETCH_MAX
+    )
     model = records._name
     ids = records.with_context(prefetch_fields=False).ids
     for i in range(0, len(ids), size):
diff --git a/tests/test_openupgradelib.py b/tests/test_openupgradelib.py
index f504b47b..3d0d056c 100644
--- a/tests/test_openupgradelib.py
+++ b/tests/test_openupgradelib.py
@@ -64,6 +64,19 @@ def test_delete_translations(self):
             record.with_context(lang="fr_FR").description,
         )
 
+    def test_chunked(self):
+        records = self.env["ir.module.module"].search([])
+
+        chunked_records = self.env["ir.module.module"]
+        for chunk in openupgrade.chunked(records):
+            chunked_records += chunk
+        self.assertEqual(records, chunked_records)
+
+        chunked_records = self.env["ir.module.module"]
+        for chunk in openupgrade.chunked(records, single=True):
+            chunked_records += chunk
+        self.assertEqual(records, chunked_records)
+
     def tearDown(self):
         super().tearDown()
         self.cr.close()