From 37c5b96f2209b6e50028fa7b4ad396ef2427fd52 Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Wed, 17 Apr 2024 13:47:44 -0300 Subject: [PATCH] python dict --- dags/stellar_etl_airflow/test_sources.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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}")