switch to logging with logger

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")
 
 
@@ -113,6 +116,6 @@ def _sink_to_feast(rb: pa.RecordBatch):
                 try:
                     feature_store.push(source_name, df, to=PushMode.ONLINE)
                 except Exception as e:
-                    print(e)
+                    logger.error(f"Failed to push to Feast feature store: {e}", exc_info=True)
 
         self.ds.sink_python(_sink_to_feast)