int

stellar · Apr 19, 2024 · e36e330 · e36e330
1 parent 3d0c44f
commit e36e330
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/dags/stellar_etl_airflow/test_sources.py b/dags/stellar_etl_airflow/test_sources.py
@@ -116,10 +116,10 @@ def get_from_combinedExport(**context):
     )
 
     BQ_results = {
-        "operations": [row[0] for row in query_job.result()],
-        "trades": [row[0] for row in query_job2.result()],
-        "effects": [row[0] for row in query_job3.result()],
-        "transactions": [row[0] for row in query_job4.result()],
+        "operations": int(row[0] for row in query_job.result()),
+        "trades": int(row[0] for row in query_job2.result()),
+        "effects": int(row[0] for row in query_job3.result()),
+        "transactions": int(row[0] for row in query_job4.result()),
     }
 
     context["ti"].xcom_push(key="from BQ", value=BQ_results)