Batch expired record processing in tezos domains demo

Process expired records in batches of 1000 instead of loading all at once
to avoid memory issues with large datasets.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: Wizard1209

src/demo_tezos_domains/hooks/check_expiration.py

@@ -8,23 +8,39 @@
 if TYPE_CHECKING:
     from dipdup.datasources.tezos_tzkt import TezosTzktDatasource
 
+BATCH_SIZE = 1000
+
 
 async def check_expiration(
     ctx: HookContext,
 ) -> None:
     ds = cast('TezosTzktDatasource', next(iter(ctx.datasources.values())))
-    expiring_records = (
-        await Record.filter(expired=False, domain__expires_at__lt=datetime.utcnow()).all().prefetch_related('domain')
-    )
-
-    for record in expiring_records:
-        ctx.logger.info('Record %s expired at %s', record.id, record.domain.expires_at)
-        record.expired = True
-        await record.save()
-        if record.address:
-            ctx.logger.debug('Invalidating contract metadata for %s @ %s', record.address, record.id)
-            await ctx.update_contract_metadata(
-                network=ds.name,
-                address=record.address,
-                metadata={},  # TODO: NULL
-            )
+    total_processed = 0
+
+    while True:
+        expiring_records = (
+            await Record.filter(expired=False, domain__expires_at__lt=datetime.utcnow())
+            .limit(BATCH_SIZE)
+            .prefetch_related('domain')
+        )
+
+        if not expiring_records:
+            break
+
+        for record in expiring_records:
+            ctx.logger.info('Record %s expired at %s', record.id, record.domain.expires_at)
+            record.expired = True
+            await record.save()
+            if record.address:
+                ctx.logger.debug('Invalidating contract metadata for %s @ %s', record.address, record.id)
+                await ctx.update_contract_metadata(
+                    network=ds.name,
+                    address=record.address,
+                    metadata={},  # TODO: NULL
+                )
+
+        total_processed += len(expiring_records)
+        ctx.logger.info('Processed %s expired records so far', total_processed)
+
+    if total_processed:
+        ctx.logger.info('Finished processing %s expired records', total_processed)