diff --git a/sqlmesh/core/model/definition.py b/sqlmesh/core/model/definition.py index d8fc276dd..6ee2d99b4 100644 --- a/sqlmesh/core/model/definition.py +++ b/sqlmesh/core/model/definition.py @@ -1045,6 +1045,7 @@ def metadata_hash(self) -> str: str(self.allow_partials), gen(self.session_properties_) if self.session_properties_ else None, str(self.validate_query) if self.validate_query is not None else None, + *[gen(g) for g in self.grains], ] for audit_name, audit_args in sorted(self.audits, key=lambda a: a[0]): diff --git a/sqlmesh/migrations/v0070_include_grains_in_metadata_hash.py b/sqlmesh/migrations/v0070_include_grains_in_metadata_hash.py new file mode 100644 index 000000000..dc75ac333 --- /dev/null +++ b/sqlmesh/migrations/v0070_include_grains_in_metadata_hash.py @@ -0,0 +1,5 @@ +"""Include grains in the metadata hash.""" + + +def migrate(state_sync, **kwargs): # type: ignore + pass