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]