From e4aedbc87086e4efba5a3e859d914d4a076ec182 Mon Sep 17 00:00:00 2001 From: Cayod Date: Tue, 24 Oct 2023 14:59:58 -0300 Subject: [PATCH] update airflow variables --- airflow_variables_dev.json | 4 ++-- dags/history_ledger_transaction_with_captive_core_dag.py | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json index 8ef3c61a..77b476ca 100644 --- 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 index f03d5fcd..1ef5490c 100644 --- 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",