Skip to content

Commit dc8fba5

Browse files
authored
Merge pull request #829 from elementary-data/ele-4829-runtime-log-in-package
add runtime log to dbt package
2 parents f6d557d + aca4bbb commit dc8fba5

File tree

2 files changed

+28
-0
lines changed

2 files changed

+28
-0
lines changed

macros/edr/system/hooks/on_run_start.sql

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

77
{% do elementary.recommend_dbt_core_artifacts_upgrade() %}
88
{% do elementary.ensure_materialize_override() %}
9+
{% set runtime_config = elementary.get_elementary_runtime_config(include_defaults=false) %}
10+
{% set elementary_database, elementary_schema = elementary.get_package_database_and_schema() %}
11+
{% set elementary_version = elementary.get_elementary_package_version() %}
12+
{% set runtime = {
13+
"config": runtime_config,
14+
"dbt_version": dbt_version,
15+
"elementary_version": elementary_version,
16+
"database": elementary_database,
17+
"schema": elementary_schema,
18+
} %}
19+
{% do elementary.edr_log("Runtime data: " ~ tojson(runtime), info=True) %}
920
{% do elementary.init_elementary_graph() %}
1021

1122
{% if elementary.is_test_command() %}

macros/edr/system/system_utils/get_config_var.sql

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,20 @@
1+
{% macro get_elementary_runtime_config(include_defaults=true) %}
2+
{% set default_config = elementary.get_default_config() %}
3+
{% set unset = '<ELEMENTARY_UNSET_MAGIC_STRING>' %}
4+
{% set runtime_config = {} %}
5+
{% for var_name in default_config.keys() %}
6+
{% if include_defaults %}
7+
{% set var_value = var(var_name, default_config.get(var_name)) %}
8+
{% else %}
9+
{% set var_value = var(var_name, unset) %}
10+
{% endif %}
11+
{% if var_value != unset %}
12+
{% do runtime_config.update({var_name: var_value}) %}
13+
{% endif %}
14+
{% endfor %}
15+
{% do return(runtime_config) %}
16+
{% endmacro %}
17+
118
{% macro get_config_var(var_name) %}
219
{% set default_config = elementary.get_default_config() %}
320
{% set var_value = var(var_name, default_config.get(var_name)) %}

0 commit comments

Comments
 (0)