Skip to content

Commit

Permalink
Corresponding PR to DBT PR for removing current_* timestamps (#481)
Browse files Browse the repository at this point in the history
* update dbt image

* Update dbt image

* Update dbt image

* update dbt image

* update dbt image

* update dbt image

* update dbt image

* update dbt image

* update dbt image

* Use ts instead of ds

* update dbt image

* Update image
  • Loading branch information
amishas157 authored Aug 23, 2024
1 parent 7e09ba9 commit ca8bfee
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion airflow_variables_dev.json
Original file line number Diff line number Diff line change
@@ -123,7 +123,7 @@
"partnership_assets__account_holders_activity_fact": false,
"partnership_assets__asset_activity_fact": false
},
"dbt_image_name": "stellar/stellar-dbt:e58c444a5",
"dbt_image_name": "stellar/stellar-dbt:333f8f1df",
"dbt_internal_source_db": "test-hubble-319619",
"dbt_internal_source_schema": "test_crypto_stellar_internal",
"dbt_job_execution_timeout_seconds": 300,
2 changes: 1 addition & 1 deletion airflow_variables_prod.json
Original file line number Diff line number Diff line change
@@ -124,7 +124,7 @@
"partnership_assets__asset_activity_fact": false,
"trade_agg": false
},
"dbt_image_name": "stellar/stellar-dbt:e58c444a5",
"dbt_image_name": "stellar/stellar-dbt:333f8f1df",
"dbt_internal_source_db": "hubble-261722",
"dbt_internal_source_schema": "crypto_stellar_internal_2",
"dbt_job_execution_timeout_seconds": 1800,
4 changes: 2 additions & 2 deletions dags/stellar_etl_airflow/build_dbt_task.py
Original file line number Diff line number Diff line change
@@ -132,7 +132,7 @@ def dbt_task(
"INTERNAL_SOURCE_SCHEMA": "{{ var.value.dbt_internal_source_schema }}",
"PUBLIC_SOURCE_DB": "{{ var.value.dbt_public_source_db }}",
"PUBLIC_SOURCE_SCHEMA": "{{ var.value.dbt_public_source_schema }}",
"EXECUTION_DATE": "{{ ds }}",
"EXECUTION_DATE": "{{ ts }}",
},
image=dbt_image,
arguments=args,
@@ -173,7 +173,7 @@ def build_dbt_task(

create_dbt_profile_cmd = create_dbt_profile(project)

execution_date = "EXECUTION_DATE=" + "{{ ds }}"
execution_date = "EXECUTION_DATE=" + "{{ ts }}"

command = ["sh", "-c"]
args = [

0 comments on commit ca8bfee

Please sign in to comment.