feat: make project-scoped artifact filtering opt-in via config var

Add `upload_only_current_project_artifacts` config var (default: false)
that, when enabled, filters graph entities by `package_name` so only
artifacts from the current dbt project are uploaded -- excluding those
from dependency packages.

A shared `filter_to_current_project` helper macro centralizes the
filtering logic and is called by all 7 upload_dbt_*.sql macros.

Addresses PR #793 feedback from @elazarlachkar and @michael-myaskovsky.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: haritamar

macros/edr/dbt_artifacts/filter_to_current_project.sql

@@ -0,0 +1,9 @@
+{%- macro filter_to_current_project(entities) -%}
+    {%- if elementary.get_config_var("upload_only_current_project_artifacts") -%}
+        {% set project_name = elementary.get_project_name() %}
+        {% do return(
+            entities | selectattr("package_name", "==", project_name) | list
+        ) %}
+    {%- else -%} {% do return(entities | list) %}
+    {%- endif -%}
+{%- endmacro -%}

macros/edr/dbt_artifacts/upload_dbt_columns.sql

@@ -1,7 +1,9 @@
 {%- macro upload_dbt_columns(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation("dbt_columns") %}
     {% if execute and relation %}
-        {% set tables = graph.nodes.values() | list + graph.sources.values() | list %}
+        {% set tables = elementary.filter_to_current_project(
+            graph.nodes.values()
+        ) + elementary.filter_to_current_project(graph.sources.values()) %}
         {% do elementary.upload_artifacts_to_table(
             relation,
             tables,

macros/edr/dbt_artifacts/upload_dbt_exposures.sql

@@ -1,8 +1,9 @@
 {%- macro upload_dbt_exposures(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation("dbt_exposures") %}
     {% if execute and relation %}
-        {% set exposures = graph.exposures.values() | selectattr(
-            "resource_type", "==", "exposure"
+        {% set exposures = elementary.filter_to_current_project(
+            graph.exposures.values()
+            | selectattr("resource_type", "==", "exposure")
         ) %}
         {% do elementary.upload_artifacts_to_table(
             relation,

macros/edr/dbt_artifacts/upload_dbt_models.sql

@@ -1,8 +1,8 @@
 {%- macro upload_dbt_models(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation("dbt_models") %}
     {% if execute and relation %}
-        {% set models = graph.nodes.values() | selectattr(
-            "resource_type", "==", "model"
+        {% set models = elementary.filter_to_current_project(
+            graph.nodes.values() | selectattr("resource_type", "==", "model")
         ) %}
         {% do elementary.upload_artifacts_to_table(
             relation,

macros/edr/dbt_artifacts/upload_dbt_seeds.sql

@@ -1,8 +1,8 @@
 {%- macro upload_dbt_seeds(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation("dbt_seeds") %}
     {% if execute and relation %}
-        {% set seeds = graph.nodes.values() | selectattr(
-            "resource_type", "==", "seed"
+        {% set seeds = elementary.filter_to_current_project(
+            graph.nodes.values() | selectattr("resource_type", "==", "seed")
         ) %}
         {% do elementary.upload_artifacts_to_table(
             relation,

macros/edr/dbt_artifacts/upload_dbt_snapshots.sql

@@ -1,8 +1,9 @@
 {%- macro upload_dbt_snapshots(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation("dbt_snapshots") %}
     {% if execute and relation %}
-        {% set snapshots = graph.nodes.values() | selectattr(
-            "resource_type", "==", "snapshot"
+        {% set snapshots = elementary.filter_to_current_project(
+            graph.nodes.values()
+            | selectattr("resource_type", "==", "snapshot")
         ) %}
         {% do elementary.upload_artifacts_to_table(
             relation,

macros/edr/dbt_artifacts/upload_dbt_sources.sql

@@ -1,8 +1,9 @@
 {%- macro upload_dbt_sources(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation("dbt_sources") %}
     {% if execute and relation %}
-        {% set sources = graph.sources.values() | selectattr(
-            "resource_type", "==", "source"
+        {% set sources = elementary.filter_to_current_project(
+            graph.sources.values()
+            | selectattr("resource_type", "==", "source")
         ) %}
         {% do elementary.upload_artifacts_to_table(
             relation,

macros/edr/dbt_artifacts/upload_dbt_tests.sql

@@ -1,8 +1,8 @@
 {%- macro upload_dbt_tests(should_commit=false, metadata_hashes=none) -%}
     {% set relation = elementary.get_elementary_relation("dbt_tests") %}
     {% if execute and relation %}
-        {% set tests = graph.nodes.values() | selectattr(
-            "resource_type", "==", "test"
+        {% set tests = elementary.filter_to_current_project(
+            graph.nodes.values() | selectattr("resource_type", "==", "test")
         ) %}
         {% do elementary.upload_artifacts_to_table(
             relation,
@@ -124,7 +124,7 @@
             {% set test_model_name_matches = modules.re.findall(
                 "ref\(['\"](\w+)['\"]\)", test_model_jinja
             ) + modules.re.findall(
-                "source\(['\"]\w+['\"], ['\"](\w+)['\"]\)", test_model_jinja
+                "source\(['\"]\w+['\"], ['\"](\ w+)['\"]\)", test_model_jinja
             ) %}
             {% if test_model_name_matches | length == 1 %}
                 {% set test_model_name = test_model_name_matches[0] %}

macros/edr/system/system_utils/get_config_var.sql

@@ -144,6 +144,7 @@
         "disable_samples_on_pii_tags": false,
         "pii_tags": ["pii"],
         "bigquery_disable_partitioning": false,
+        "upload_only_current_project_artifacts": false,
     } %}
     {{- return(default_config) -}}
 {%- endmacro -%}