diff --git a/src/dbt_osmosis/core/osmosis.py b/src/dbt_osmosis/core/osmosis.py index 5fe5669..0138ad4 100644 --- a/src/dbt_osmosis/core/osmosis.py +++ b/src/dbt_osmosis/core/osmosis.py @@ -631,7 +631,7 @@ def draft_project_structure_update_plan(self) -> Dict[Path, SchemaFileMigration] futs.append(self.tpe.submit(self._draft, schema_file, unique_id, blueprint)) wait(futs) return blueprint - + def cleanup_blueprint(self, blueprint: dict) -> None: with self.mutex: for k in list(blueprint.keys()): @@ -661,7 +661,7 @@ def commit_project_restructure_to_disk( # Build blueprint if not user supplied if not blueprint: blueprint = self.draft_project_structure_update_plan() - + blueprint = self.cleanup_blueprint(blueprint) # Verify we have actions in the plan