chore: update uv.lock (#55)

* chore: update uv.lock

* fix: fix typing annotations

Author: ravenac95

dagster_sqlmesh/resource.py

@@ -369,7 +369,7 @@ def process_events(self, event: console.ConsoleEvent) -> None:
 
     def notify_success(
         self, sqlmesh_context: SQLMeshContext
-    ) -> t.Iterator[dg.MaterializeResult]:
+    ) -> t.Iterator[dg.MaterializeResult[t.Any]]:
         notify = self._tracker.notify_queue_next()
 
         while notify is not None:
@@ -412,7 +412,7 @@ def create_materialize_result(
         context: dg.AssetExecutionContext,
         asset_key: dg.AssetKey,
         current_materialization_status: ModelMaterializationStatus,
-    ) -> dg.MaterializeResult:
+    ) -> dg.MaterializeResult[t.Any]:
         last_materialization = context.instance.get_latest_materialization_event(
             asset_key
         )
@@ -598,7 +598,7 @@ def run(
         plan_options: PlanOptions | None = None,
         run_options: RunOptions | None = None,
         materializations_enabled: bool = True,
-    ) -> t.Iterable[dg.MaterializeResult]:
+    ) -> t.Iterable[dg.MaterializeResult[t.Any]]:
         """Execute SQLMesh based on the configuration given"""
         plan_options = plan_options or {}
         run_options = run_options or {}

sample/dagster_project/definitions.py

@@ -53,7 +53,7 @@ def get_group_name(self, context, model):
 
 
 @asset(key=["sources", "reset_asset"])
-def reset_asset() -> MaterializeResult:
+def reset_asset() -> MaterializeResult[t.Any]:
     """An asset used for testing this entire workflow. If the duckdb database is
     found, this will delete it. This allows us to continously test this dag if
     this specific asset is materialized
@@ -108,7 +108,7 @@ def post_full_model() -> pl.DataFrame:
 )
 def sqlmesh_project(
     context: AssetExecutionContext, sqlmesh: SQLMeshResource
-) -> t.Iterator[MaterializeResult]:
+) -> t.Iterator[MaterializeResult[t.Any]]:
     yield from sqlmesh.run(context)