diff --git a/dagster_sqlmesh/resource.py b/dagster_sqlmesh/resource.py index c48b2ac..0a41e41 100644 --- a/dagster_sqlmesh/resource.py +++ b/dagster_sqlmesh/resource.py @@ -296,8 +296,6 @@ def run( sqlmesh_model_name_to_key(model.name) in context.selected_output_names ): - logger.info(f"selected model: {model.name}") - models_map[key] = model select_models.append(model.name) selected_models_set = set(models_map.keys()) @@ -308,6 +306,8 @@ def run( # Setting this to none to allow sqlmesh to select all models and # also remove any models select_models = None + else: + logger.info(f"selected models: {select_models}") event_handler = DagsterSQLMeshEventHandler( context, models_map, dag, "sqlmesh: " diff --git a/pyproject.toml b/pyproject.toml index 22f093b..46d5c5e 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "dagster-sqlmesh" -version = "0.11.1" +version = "0.11.2" description = "" authors = [ {name = "Reuven Gonzales", email = "reuven@karibalabs.co"} diff --git a/uv.lock b/uv.lock index 5b8628c..b5a67d0 100644 --- a/uv.lock +++ b/uv.lock @@ -287,7 +287,7 @@ wheels = [ [[package]] name = "dagster-sqlmesh" -version = "0.11.1" +version = "0.11.2" source = { editable = "." } dependencies = [ { name = "dagster" },