Update main.py

main.py

@@ -60,7 +60,7 @@ async def process_batch_data(batch_id: str):
 
             supa_data = []
             for resp in res:
-                id = resp.get('custom_id').split('__')
+                id = resp.get('custom_id').split('*')
                 message_id = id[0]
                 user_id = id[1]
                 email = id[2]