update

Author: toriwei

sqlmesh/dbt/loader.py

@@ -172,16 +172,8 @@ def _load_audits(
                 for test in package.tests.values():
                     logger.debug("Converting '%s' to sqlmesh format", test.name)
                     try:
-                        sqlmesh_audit = test.to_sqlmesh(package_context)
-                        qualified_name = f"{package.name}.{test.name}"
-                        is_from_dbt_packages = "dbt_packages" in str(test.path)
-
-                        if is_from_dbt_packages:
-                            audits[qualified_name] = sqlmesh_audit
-                            if test.name not in audits:
-                                audits[test.name] = sqlmesh_audit
-                        else:
-                            audits[test.name] = sqlmesh_audit
+                        audit = test.to_sqlmesh(package_context)
+                        audits[audit.name] = audit
 
                     except BaseMissingReferenceError as e:
                         ref_type = "model" if isinstance(e, MissingModelError) else "source"

sqlmesh/dbt/test.py

@@ -151,6 +151,9 @@ def to_sqlmesh(self, context: DbtContext) -> Audit:
         blocking = self.severity == Severity.ERROR
 
         audit: Audit
+        if self.package_name != context.project_name:
+            self.name = f"{self.package_name}.{self.name}"
+
         if self.is_standalone:
             jinja_macros.add_globals({"this": self.relation_info})
             audit = StandaloneAudit(