|
12 | 12 |
|
13 | 13 | from dbt import constants as dbt_constants, flags |
14 | 14 |
|
15 | | -from sqlmesh.utils.conversions import serializable |
| 15 | +from sqlmesh.utils.conversions import make_serializable |
16 | 16 |
|
17 | 17 | # Override the file name to prevent dbt commands from invalidating the cache. |
18 | 18 | dbt_constants.PARTIAL_PARSE_FILE_NAME = "sqlmesh_partial_parse.msgpack" |
@@ -161,30 +161,31 @@ def all_macros(self) -> t.Dict[str, t.Dict[str, MacroInfo]]: |
161 | 161 | def flat_graph(self) -> t.Dict[str, t.Any]: |
162 | 162 | return { |
163 | 163 | "exposures": { |
164 | | - k: serializable(v.to_dict(omit_none=False)) |
| 164 | + k: make_serializable(v.to_dict(omit_none=False)) |
165 | 165 | for k, v in getattr(self._manifest, "exposures", {}).items() |
166 | 166 | }, |
167 | 167 | "groups": { |
168 | | - k: serializable(v.to_dict(omit_none=False)) |
| 168 | + k: make_serializable(v.to_dict(omit_none=False)) |
169 | 169 | for k, v in getattr(self._manifest, "groups", {}).items() |
170 | 170 | }, |
171 | 171 | "metrics": { |
172 | | - k: serializable(v.to_dict(omit_none=False)) |
| 172 | + k: make_serializable(v.to_dict(omit_none=False)) |
173 | 173 | for k, v in getattr(self._manifest, "metrics", {}).items() |
174 | 174 | }, |
175 | 175 | "nodes": { |
176 | | - k: serializable(v.to_dict(omit_none=False)) for k, v in self._manifest.nodes.items() |
| 176 | + k: make_serializable(v.to_dict(omit_none=False)) |
| 177 | + for k, v in self._manifest.nodes.items() |
177 | 178 | }, |
178 | 179 | "sources": { |
179 | | - k: serializable(v.to_dict(omit_none=False)) |
| 180 | + k: make_serializable(v.to_dict(omit_none=False)) |
180 | 181 | for k, v in self._manifest.sources.items() |
181 | 182 | }, |
182 | 183 | "semantic_models": { |
183 | | - k: serializable(v.to_dict(omit_none=False)) |
| 184 | + k: make_serializable(v.to_dict(omit_none=False)) |
184 | 185 | for k, v in getattr(self._manifest, "semantic_models", {}).items() |
185 | 186 | }, |
186 | 187 | "saved_queries": { |
187 | | - k: serializable(v.to_dict(omit_none=False)) |
| 188 | + k: make_serializable(v.to_dict(omit_none=False)) |
188 | 189 | for k, v in getattr(self._manifest, "saved_queries", {}).items() |
189 | 190 | }, |
190 | 191 | } |
|
0 commit comments