Skip to content

Commit 1595b82

Browse files
committed
handle duplicate audit names
1 parent d41c3e0 commit 1595b82

File tree

1 file changed

+11
-1
lines changed

1 file changed

+11
-1
lines changed

sqlmesh/dbt/loader.py

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,17 @@ def _load_audits(
172172
for test in package.tests.values():
173173
logger.debug("Converting '%s' to sqlmesh format", test.name)
174174
try:
175-
audits[test.name] = test.to_sqlmesh(package_context)
175+
sqlmesh_audit = test.to_sqlmesh(package_context)
176+
qualified_name = f"{package.name}.{test.name}"
177+
is_from_dbt_packages = "dbt_packages" in str(test.path)
178+
179+
if is_from_dbt_packages:
180+
audits[qualified_name] = sqlmesh_audit
181+
if test.name not in audits:
182+
audits[test.name] = sqlmesh_audit
183+
else:
184+
audits[test.name] = sqlmesh_audit
185+
176186
except BaseMissingReferenceError as e:
177187
ref_type = "model" if isinstance(e, MissingModelError) else "source"
178188
logger.warning(

0 commit comments

Comments
 (0)