Update extract_insights.py

extract_insights.py

@@ -234,7 +234,8 @@ async def process_synchronous_job(dataset: Dict[str, Any]):
             insert_data['email'] = email
             insert_data['user_id'] = user_id
             insert_data['message_id'] = message_id
-            insert_data['total_cost'] = parse_number(insert_data['total_cost'])
+            if isinstance(insert_data['total_cost'], str) and ',' in insert_data['total_cost']:
+                insert_data['total_cost'] = parse_number(insert_data['total_cost'])
             print("Printing user_id")
             print(user_id)