From 4324e37d562622cc54a4e2ced412b1a84cf1f8ab Mon Sep 17 00:00:00 2001 From: Laysa de Sousa Bitencourt Date: Wed, 17 Apr 2024 15:52:27 -0300 Subject: [PATCH] pre-commit --- dags/stellar_etl_airflow/test_sources.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py index 9f151c4c..6f4e0889 100644 --- a/dags/stellar_etl_airflow/test_sources.py +++ b/dags/stellar_etl_airflow/test_sources.py @@ -54,12 +54,12 @@ def compare_transforms_and_bq_rows(): client = bigquery.Client(credentials=credentials, project=credentials.project_id) # # Query number of rows in BigQuery table - query_job = client.query(f"SELECT + 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; - " + """ ) results = query_job.result() bq_rows = [row for row in results][0][0]