diff --git a/run.py b/run.py
index e7c2352..73d619f 100644
--- a/run.py
+++ b/run.py
@@ -254,7 +254,7 @@ def run():
     # Copiar ConvLeadsLakeMes → ConvLeadsLakeMesFinal (snapshot diario)
     final_leads_data = [
         {"airtable_id": item["campaign"]["airtable_id"],
-         "conv_leads_lake_mes": item["campaign"]["conv_leads_lake_mes"]}
+         "conv_leads_lake_mes": item["leads"]}
         for item in collected
     ]
     if final_leads_data: