From 08c0eceee5416ef07a566c81209567bda79f6c4b Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Wed, 17 Apr 2024 16:15:31 -0300 Subject: [PATCH] results --- dags/stellar_etl_airflow/test_sources.py | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index 505e3a93..2445f922 100644 --- a/dags/stellar_etl_airflow/test_sources.py +++ b/dags/stellar_etl_airflow/test_sources.py @@ -57,14 +57,11 @@ def compare_transforms_and_bq_rows(): query_job = client.query( """SELECT (SELECT COUNT(*) FROM crypto-stellar.crypto_stellar.history_ledgers - WHERE DATE(batch_run_date)='2020-04-16') AS count_public, - (SELECT COUNT(*) FROM hubble-261722.crypto_stellar_internal_2.account_signers - WHERE DATE(batch_run_date)='2020-04-16') AS count_internal; + WHERE DATE(batch_run_date)='2020-04-16') AS count_public """ ) results = query_job.result() - bq_rows = [row for row in results][0][0] - print(f"bq_rows are: {bq_rows}") + print(f"results are: {results}") # # Compare successful_transforms and bq_rows # if successful_transforms_ledgers != bq_rows: