Skip to content

Commit 77702e8

Browse files
committed
added access to model schema
1 parent 83b0d9b commit 77702e8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

macros/edr/dbt_artifacts/upload_dbt_models.sql

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
('unique_key', 'string'),
3232
('incremental_strategy', 'string'),
3333
('group_name', 'string'),
34+
('access', 'string'),
3435
] %}
3536
{% if target.type == "bigquery" or elementary.get_config_var("include_other_warehouse_specific_columns") %}
3637
{% do columns.extend([('bigquery_partition_by', 'string'), ('bigquery_cluster_by', 'string')]) %}
@@ -63,7 +64,7 @@
6364
{% set meta_tags = elementary.safe_get_with_default(meta_dict, 'tags', []) %}
6465
{% set tags = elementary.union_lists(config_tags, global_tags) %}
6566
{% set tags = elementary.union_lists(tags, meta_tags) %}
66-
67+
6768
{% set flatten_model_metadata_dict = {
6869
'unique_id': node_dict.get('unique_id'),
6970
'alias': node_dict.get('alias'),
@@ -88,6 +89,7 @@
8889
'bigquery_partition_by': config_dict.get("partition_by"),
8990
'bigquery_cluster_by': config_dict.get("cluster_by"),
9091
'group_name': config_dict.get("group") or node_dict.get("group"),
92+
'access': config_dict.get("access") or node_dict.get("access"),
9193
} %}
9294
{% do flatten_model_metadata_dict.update({"metadata_hash": elementary.get_artifact_metadata_hash(flatten_model_metadata_dict)}) %}
9395
{{ return(flatten_model_metadata_dict) }}

0 commit comments

Comments
 (0)