try #4

jfw-ppi · jfw-ppi · commit 069127776d8e · 2025-12-28T17:50:14.000+01:00
diff --git a/sdk/python/feast/infra/compute_engines/local/nodes.py b/sdk/python/feast/infra/compute_engines/local/nodes.py
@@ -263,9 +263,14 @@ def execute(self, context: ExecutionContext) -> ArrowTableValue:
         if input_table.num_rows == 0:
             return input_table
 
-        chunk_size = getattr(
+        raw_chunk_size = getattr(
             getattr(context.repo_config, "batch_engine", None), "chunk_size", None
         )
+        try:
+            chunk_size = int(raw_chunk_size) if raw_chunk_size is not None else None
+        except (TypeError, ValueError):
+            chunk_size = None
+
         if chunk_size and chunk_size > 0:
             batches = input_table.to_batches(max_chunksize=chunk_size)
         else:
