fix: index out of range error in feast integration (#68)

* fix: index out of range error in feast integration

* switch to logging with logger

* version bump

* update gitignore

* fix lint errors

.gitignore

@@ -3,3 +3,4 @@
 .DS_Store
 .ipynb_checkpoints/
 Untitled.ipynb
+*.o

py-denormalized/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "denormalized-python"
-version = "0.0.11"
+version = "0.0.12"
 edition = "2021"
 homepage = "https://github.com/probably-nothing-labs/denormalized.git"
 repository = "https://github.com/probably-nothing-labs/denormalized.git"

py-denormalized/pyproject.toml

@@ -28,6 +28,7 @@ dev = [
     "jupyterlab>=4.3.0",
     "pdoc>=15.0.0",
     "pip>=24.3.1",
+    "ruff>=0.8.2",
 ]
 docs = [
     "pdoc>=15.0.0",

py-denormalized/python/denormalized/feast_data_stream.py

@@ -1,4 +1,5 @@
 import inspect
+import logging
 from typing import Any, TypeVar, Union, cast, get_type_hints
 
 import pyarrow as pa
@@ -10,6 +11,8 @@
 
 from .data_stream import DataStream
 
+logger = logging.getLogger(__name__)
+
 T = TypeVar("T")
 
 
@@ -108,10 +111,13 @@ def write_feast_feature(
         """
 
         def _sink_to_feast(rb: pa.RecordBatch):
-            df = rb.to_pandas()
-            try:
-                feature_store.push(source_name, df, to=PushMode.ONLINE)
-            except Exception as e:
-                print(e)
+            if len(rb):
+                df = rb.to_pandas()
+                try:
+                    feature_store.push(source_name, df, to=PushMode.ONLINE)
+                except Exception as e:
+                    logger.error(
+                        f"Failed to push to Feast feature store: {e}", exc_info=True
+                    )
 
         self.ds.sink_python(_sink_to_feast)