udpate image

udpate image udpate image udpate image
stellar · Dec 6, 2024 · c1aa6df · c1aa6df
1 parent 30ee494
commit c1aa6df
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/airflow_variables_dev.json b/airflow_variables_dev.json
@@ -315,7 +315,7 @@
   "schema_filepath": "/home/airflow/gcs/dags/schemas/",
   "sentry_dsn": "https://[email protected]/6190849",
   "sentry_environment": "development",
-  "stellar_etl_internal_image_name": "stellar/stellar-etl:204d343fa",
+  "stellar_etl_internal_image_name": " amishastellar/stellar-etl-internal:ab0a13897",
   "table_ids": {
     "accounts": "accounts",
     "assets": "history_assets",

diff --git a/dags/external_data_dag.py b/dags/external_data_dag.py
@@ -4,10 +4,11 @@
 """
 
 from ast import literal_eval
-from datetime import datetime
+from datetime import datetime, timedelta
 from json import loads
 
 from airflow import DAG
+from airflow.configuration import conf
 from airflow.models.variable import Variable
 from airflow.providers.cncf.kubernetes.operators.pod import KubernetesPodOperator
 from kubernetes.client import models as k8s
@@ -56,8 +57,6 @@ def stellar_etl_internal_task(
 
     image = "{{ var.value.stellar_etl_internal_image_name }}"
 
-    logging.info(f"sh commands to run in pod: {args}")
-
     return KubernetesPodOperator(
         task_id=task_name,
         name=task_name,