diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py
index 28a22bf0..b3336ae0 100644
--- a/dags/stellar_etl_airflow/test_sources.py
+++ b/dags/stellar_etl_airflow/test_sources.py
@@ -32,9 +32,8 @@ def compare_transforms_and_bq_rows():
         xcom_ledgers = ti.xcom_pull(task_ids=task.task_id, key="return_value")
 
         # Parse JSON and get successful_transforms
-        successful_transforms_ledgers = json.loads(xcom_ledgers)[
-            "successful_transforms"
-        ]
+        successful_transforms_ledgers = xcom_ledgers["successful_transforms"]
+        
         total_successful_transforms += successful_transforms_ledgers
 
     print(f"Total successful transforms for yesterday: {total_successful_transforms}")