diff --git a/src/dataflow/iris_feature_pipeline.py b/src/dataflow/iris_feature_pipeline.py
index 9d28334..37f8823 100644
--- a/src/dataflow/iris_feature_pipeline.py
+++ b/src/dataflow/iris_feature_pipeline.py
@@ -74,6 +74,7 @@ def process(self, element):
         }
 
         sample_id = element.get("sample_id") or uuid.uuid4().hex[:8]
+        logger.info(f"Processing entity_id: {sample_id}_streaming")
         row["species"] = None
         row["source"] = "streaming"
         row["entity_id"] = f"{sample_id}_streaming"