fix: modify calls to translator to pass fqn instead

This fixes the error where materialisations return wrong asset keys, and hence can't be marked
as completed on Dagster.

Author: lucargir

dagster_sqlmesh/config.py

@@ -26,10 +26,8 @@ class SQLMeshContextConfig(Config):
     gateway: str
     config_override: dict[str, Any] | None = Field(default_factory=lambda: None)
 
-
     @property
     def sqlmesh_config(self) -> MeshConfig | None:
         if self.config_override:
             return MeshConfig.parse_obj(self.config_override)
-        return None
-
+        return None

dagster_sqlmesh/resource.py

@@ -146,7 +146,8 @@ def notify_success(
             # We allow selecting models. That value is mapped to models_map.
             # If the model is not in models_map, we can skip any notification
             if model:
-                output_key = self.translator.get_asset_key_str(model.name)
+                # Passing model.fqn to translator
+                output_key = self.translator.get_asset_key_str(model.fqn)
                 asset_key = self._context.asset_key_for_output(output_key)
                 yield MaterializeResult(
                     asset_key=asset_key,
@@ -302,7 +303,7 @@ def run(
                 models_map = {}
                 for key, model in models.items():
                     if (
-                        translator.get_sqlmesh_model_name_from_key_str(model.name)
+                        translator.get_asset_key_str(model.fqn)
                         in context.selected_output_names
                     ):
                         models_map[key] = model