diff --git a/macros/edr/dbt_artifacts/upload_dbt_invocation.sql b/macros/edr/dbt_artifacts/upload_dbt_invocation.sql index 960f084b5..5f2de3ab3 100644 --- a/macros/edr/dbt_artifacts/upload_dbt_invocation.sql +++ b/macros/edr/dbt_artifacts/upload_dbt_invocation.sql @@ -158,7 +158,7 @@ {% set airflow_job_url = server_url ~ "/dags/" ~ job_id ~ "/grid" %} {% do return(airflow_job_url) %} {% elif orchestrator == 'dbt_cloud' %} - {% set account_id = elementary.get_var('account_id', ['DBT_ACCOUNT_ID']) %} + {% set account_id = elementary.get_var('account_id', ['DBT_CLOUD_ACCOUNT_ID']) %} {% set dbt_cloud_project_id = elementary.get_first_env_var(['DBT_CLOUD_PROJECT_ID']) %} {% set dbt_cloud_job_id = elementary.get_first_env_var(['DBT_CLOUD_JOB_ID']) %}