update airflow variables

stellar · Oct 24, 2023 · e4aedbc · e4aedbc
1 parent b230602
commit e4aedbc
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json
@@ -140,7 +140,7 @@
     "config_settings": "config_settings.txt",
     "expiration": "expiration.txt",
     "diagnostic_events": "diagnostic_events.txt",
-    "ledger_transactions": "ledger_transactions.txt"
+    "ledger_transaction": "ledger_transaction.txt"
   },
   "output_path": "/home/airflow/gcs/data/",
   "owner": "SDF",
@@ -278,7 +278,7 @@
     "config_settings": "config_settings",
     "expiration": "expiration",
     "diagnostic_events": "diagnostic_events",
-    "ledger_transactions": "ledger_transactions"
+    "ledger_transaction": "ledger_transaction"
   },
   "task_timeout": {
     "build_batch_stats": 180,

diff --git a/dags/history_ledger_transaction_with_captive_core_dag.py b/dags/history_ledger_transaction_with_captive_core_dag.py
@@ -55,7 +55,7 @@
 record is written to an internal dataset for data eng use only.
 """
 
-write_lt_stats = build_batch_stats(dag, table_names["ledger_transactions"])
+write_lt_stats = build_batch_stats(dag, table_names["ledger_transaction"])
 
 """
 The export tasks call export commands on the Stellar ETL using the ledger range from the time task.
@@ -71,8 +71,8 @@
 lt_export_task = build_export_task(
     dag,
     "archive",
-    "export_ledger_transactions",
-    file_names["ledger_transactions"],
+    "export_ledger_transaction",
+    file_names["ledger_transaction"],
     use_testnet=use_testnet,
     use_gcs=True,
     resource_cfg="cc",