python dict

stellar · Apr 17, 2024 · 37c5b96 · 37c5b96
1 parent a5bfa92
commit 37c5b96
Showing 1 changed file with 2 additions and 3 deletions.
diff --git 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}")