Skip to content

Commit

Permalink
pre-commit
Browse files Browse the repository at this point in the history
  • Loading branch information
laysabit committed Apr 17, 2024
1 parent c610a56 commit 4324e37
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions dags/stellar_etl_airflow/test_sources.py
Original file line number Diff line number Diff line change
Expand Up @@ -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]
Expand Down

0 comments on commit 4324e37

Please sign in to comment.