Skip to content

Commit 91b0dde

Browse files
committed
add runtime log to dbt package
1 parent f6d557d commit 91b0dde

File tree

2 files changed

+19
-0
lines changed

2 files changed

+19
-0
lines changed

macros/edr/system/hooks/on_run_start.sql

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,15 @@
66

77
{% do elementary.recommend_dbt_core_artifacts_upgrade() %}
88
{% do elementary.ensure_materialize_override() %}
9+
{% set runtime_config = elementary.get_elementary_runtime_config() %}
10+
{% set elementary_database, elementary_schema = elementary.get_package_database_and_schema() %}
11+
{% set runtime = {
12+
"config": runtime_config,
13+
"dbt_version": dbt_version,
14+
"database": elementary_database,
15+
"schema": elementary_schema,
16+
} %}
17+
{% do log("Elementary runtime: " ~ tojson(runtime), info=True) %}
918
{% do elementary.init_elementary_graph() %}
1019

1120
{% if elementary.is_test_command() %}

macros/edr/system/system_utils/get_config_var.sql

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,13 @@
1+
{% macro get_elementary_runtime_config() %}
2+
{% set default_config = elementary.get_default_config() %}
3+
{% set runtime_config = {} %}
4+
{% for var_name in default_config.keys() %}
5+
{% set var_value = var(var_name, default_config.get(var_name)) %}
6+
{% do runtime_config.update({var_name: var_value}) %}
7+
{% endfor %}
8+
{% do return(runtime_config) %}
9+
{% endmacro %}
10+
111
{% macro get_config_var(var_name) %}
212
{% set default_config = elementary.get_default_config() %}
313
{% set var_value = var(var_name, default_config.get(var_name)) %}

0 commit comments

Comments
 (0)