Update main.py

main.py

@@ -10,6 +10,7 @@ from kafka import KafkaConsumer, KafkaProducer
 import asyncio
 import json
 import pandas as pd
+from datetime import datetime
 
 
 app = FastAPI()
@@ -75,7 +76,8 @@ def predict_file_responses(file: UploadFile = File(...)):
             review_id = row['REVIEWID']
             raw_data = {"text":text, "star_rating":star_rating, "skip":False}
             processed_data, has_sentiments = process_single_comment(raw_data) 
-            print(f"Processed review with index {index}")
+            now = datetime.now()
+            print(f"Processed review with index {index} at time {now.time()}")
             processed_data_list.append({"processed_data":processed_data, "has_sentiments":has_sentiments, "review_id":review_id})
         finally:
             pass