fix(jira): tag staging feeders 'staging' so silver builds on a fresh install (#1893)

src/ingestion/connectors/task-tracking/jira/dbt/jira__task_comments.sql

@@ -7,7 +7,7 @@
     engine='ReplacingMergeTree(_version)',
     order_by=['unique_key'],
     settings={'allow_nullable_key': 1},
-    tags=['jira', 'silver:class_task_comments']
+    tags=['jira', 'staging', 'silver:class_task_comments']
 ) }}
 
 -- `body` is raw ADF JSON at Bronze level; plaintext extraction deferred.

src/ingestion/connectors/task-tracking/jira/dbt/jira__task_projects.sql

@@ -3,7 +3,7 @@
     materialized='view',
     alias='jira__task_projects',
     schema='staging',
-    tags=['jira', 'silver:class_task_projects']
+    tags=['jira', 'staging', 'silver:class_task_projects']
 ) }}
 
 -- View, not table: bronze `jira_projects` is MergeTree (full_refresh + overwrite),

src/ingestion/connectors/task-tracking/jira/dbt/jira__task_sprints.sql

@@ -3,7 +3,7 @@
     materialized='view',
     alias='jira__task_sprints',
     schema='staging',
-    tags=['jira', 'silver:class_task_sprints']
+    tags=['jira', 'staging', 'silver:class_task_sprints']
 ) }}
 
 -- View, not table: bronze `jira_sprints` is MergeTree (full_refresh + overwrite),

src/ingestion/connectors/task-tracking/jira/dbt/jira__task_statuses.sql

@@ -3,7 +3,7 @@
     materialized='view',
     alias='jira__task_statuses',
     schema='staging',
-    tags=['jira', 'silver:class_task_statuses']
+    tags=['jira', 'staging', 'silver:class_task_statuses']
 ) }}
 
 -- Per-source status dimension; unioned into `silver.class_task_statuses` via `union_by_tag`.

src/ingestion/connectors/task-tracking/jira/dbt/jira__task_users.sql

@@ -3,7 +3,7 @@
     materialized='view',
     alias='jira__task_users',
     schema='staging',
-    tags=['jira', 'silver:class_task_users']
+    tags=['jira', 'staging', 'silver:class_task_users']
 ) }}
 
 -- Per-source staging view; unioned into `silver.class_task_users` via

src/ingestion/connectors/task-tracking/jira/dbt/jira__task_worklogs.sql

@@ -7,7 +7,7 @@
     engine='ReplacingMergeTree(_version)',
     order_by=['unique_key'],
     settings={'allow_nullable_key': 1},
-    tags=['jira', 'silver:class_task_worklogs']
+    tags=['jira', 'staging', 'silver:class_task_worklogs']
 ) }}
 
 SELECT

src/ingestion/connectors/task-tracking/jira/dbt/jira__users_snapshot.sql

@@ -1,9 +1,17 @@
 -- depends_on: {{ ref('jira__bronze_promoted') }}
+{# `staging` tag (issue #1893): the prod jira pipeline materializes staging
+   feeders only in its staging step (`tag:staging,tag:jira`) and builds silver
+   with `tag:silver,tag:jira+`. Tagged only `jira`, this model matched neither
+   pass, so on a fresh install `staging.jira__users_snapshot` was never built and
+   the silver model `jira__users_fields_history` — which ref()s it — failed with
+   `code: 60 Unknown table expression identifier 'staging.jira__users_snapshot'`.
+   `schema='staging'` is the target DATABASE, not a dbt tag, so it does not
+   participate in tag selection. #}
 {{ config(
     materialized='incremental',
     incremental_strategy='append',
     schema='staging',
-    tags=['jira']
+    tags=['jira', 'staging']
 ) }}
 
 {{ snapshot(

src/ingestion/tests/e2e/meta/test_dbt_runner.py

@@ -76,6 +76,88 @@ def test_jira_staging_selector_includes_bronze_promoted(dbt_runner: DbtRunner) -
     )
 
 
+def test_every_jira_model_is_built_by_some_prod_pass(dbt_runner: DbtRunner) -> None:
+    """Regression guard for issue #1893 (and the whole #1886/#1893 class).
+
+    Unlike other connectors — which build via the legacy single pass
+    ``tag:<connector>+`` that pulls every connector-tagged model plus its
+    descendants — the jira pipeline builds in three narrow tag-scoped passes and
+    has NO ``tag:jira`` catch-all:
+
+      * staging: ``tag:staging,tag:jira``            (render_*.py, no ``+``)
+      * silver:  ``tag:silver,tag:jira+``            (jira descriptor dbt_select)
+      * gold:    ``tag:gold,tag:jira+``              (jira descriptor dbt_select)
+
+    A jira model tagged only ``['jira']`` (or ``['jira', 'silver:class_*']`` —
+    note ``silver:class_*`` is a routing tag, not the bare ``silver`` tag) matches
+    none of these passes, so it is never materialized. Its silver consumers then
+    fail: ``jira__users_fields_history`` ``ref()``s ``jira__users_snapshot`` and
+    dies with ``code: 60 Unknown table 'staging.jira__users_snapshot'`` (#1893),
+    and the ``class_task_*`` silver models lose their jira rows (or hit the
+    ``union_by_tag`` empty-target compiler error on a fresh install).
+
+    Assert every jira connector model is selected by at least one prod pass.
+    Ephemeral models are exempt: they have no DB relation and are inlined into
+    their consumers via ``ref()``, so no pass needs to build them standalone.
+    """
+    manifest = dbt_runner.target_dir / "manifest.json"
+    data = json.loads(manifest.read_text(encoding="utf-8"))
+    nodes = data["nodes"]
+    child_map = data.get("child_map", {})
+
+    def _tags(uid: str) -> set[str]:
+        return set(nodes[uid].get("config", {}).get("tags", []) or [])
+
+    def _descendants(seed: set[str]) -> set[str]:
+        seen: set[str] = set()
+        stack = list(seed)
+        while stack:
+            cur = stack.pop()
+            for child in child_map.get(cur, []):
+                if child not in seen:
+                    seen.add(child)
+                    stack.append(child)
+        return seen
+
+    def _select(expr: str) -> set[str]:
+        # Minimal dbt selector semantics: space = union of terms, comma =
+        # intersection of atoms, atom = ``tag:X`` optionally suffixed ``+``
+        # (the node plus all its graph descendants).
+        union: set[str] = set()
+        for term in expr.split():
+            inter: set[str] | None = None
+            for atom in term.split(","):
+                plus = atom.endswith("+")
+                tag = atom[:-1] if plus else atom
+                assert tag.startswith("tag:"), atom
+                base = {uid for uid in nodes if tag[4:] in _tags(uid)}
+                atom_set = base | _descendants(base) if plus else base
+                inter = atom_set if inter is None else (inter & atom_set)
+            union |= inter or set()
+        return union
+
+    covered = _select("tag:staging,tag:jira") | _select("tag:silver,tag:jira+") | _select("tag:gold,tag:jira+")
+
+    def _is_jira_model(node: dict) -> bool:
+        return node.get("resource_type") == "model" and (
+            "/connectors/task-tracking/jira/dbt/" in node.get("original_file_path", "")
+        )
+
+    gaps = sorted(
+        node["name"]
+        for uid, node in nodes.items()
+        if _is_jira_model(node) and node.get("config", {}).get("materialized") != "ephemeral" and uid not in covered
+    )
+
+    assert not gaps, (
+        "These non-ephemeral jira models are built by no prod pass "
+        "(tag:staging,tag:jira / tag:silver,tag:jira+ / tag:gold,tag:jira+), so on "
+        f"a real sync they are never materialized and their silver consumers fail: {gaps}. "
+        "Add the 'staging' tag (like jira__issue_field_snapshot) so the staging pass "
+        "builds them before enrich/silver (issue #1893)."
+    )
+
+
 def test_dbt_build_unknown_selector_raises(dbt_runner: DbtRunner) -> None:
     """A selector that matches no models surfaces a clear DbtError."""
     # `dbt build --select <nonsense>` is NOT an error in dbt — it just runs