From dfc2cf33e47c43b7d426d1e73e45b7d81aa7e320 Mon Sep 17 00:00:00 2001
From: Sahil Batra <shlbatra123@gmail.com>
Date: Tue, 16 Jun 2026 17:58:24 -0400
Subject: [PATCH] Add log statement for entity_id in MapToFeatureRow

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
---
 src/dataflow/iris_feature_pipeline.py | 1 +
 1 file changed, 1 insertion(+)

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"