Skip to content

Commit 85a5b5c

Browse files
authored
fix(ingest): pin lookml liquid dep (#12896)
1 parent 8fbc4d1 commit 85a5b5c

File tree

2 files changed

+6
-19
lines changed

2 files changed

+6
-19
lines changed

metadata-ingestion/setup.py

+5-1
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,11 @@
185185
"lkml>=1.3.4",
186186
*sqlglot_lib,
187187
"GitPython>2",
188-
"python-liquid",
188+
# python-liquid 2 includes a bunch of breaking changes.
189+
# See https://jg-rp.github.io/liquid/migration/
190+
# Eventually we should fully upgrade to v2, but that will require
191+
# us to drop Python 3.8 support first.
192+
"python-liquid<2",
189193
"deepmerge>=1.1.1",
190194
}
191195

metadata-ingestion/src/datahub/testing/mcp_diff.py

+1-18
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@
88
import yaml
99
from deepdiff import DeepDiff
1010
from deepdiff.model import DiffLevel
11-
from deepdiff.operator import BaseOperator
1211
from typing_extensions import Literal
1312

1413
ReportType = Literal[
@@ -59,27 +58,12 @@ def __repr__(self):
5958

6059
@dataclasses.dataclass
6160
class DeltaInfo:
62-
"""Information about an MCP used to construct a diff delta.
63-
64-
In a separate class so it can be ignored by DeepDiff via MCPDeltaInfoOperator.
65-
"""
61+
"""Information about an MCP used to construct a diff delta."""
6662

6763
idx: int # Location in list of MCEs in golden file
6864
original: Dict[str, Any] # Original json-serialized MCP
6965

7066

71-
class DeltaInfoOperator(BaseOperator):
72-
"""Warning: Doesn't seem to be working right now.
73-
Ignored via an ignore path as an extra layer of defense.
74-
"""
75-
76-
def __init__(self):
77-
super().__init__(types=[DeltaInfo])
78-
79-
def give_up_diffing(self, *args: Any, **kwargs: Any) -> bool:
80-
return True
81-
82-
8367
AspectsByUrn = Dict[str, Dict[str, List[AspectForDiff]]]
8468

8569

@@ -176,7 +160,6 @@ def create(
176160
t2=t2,
177161
exclude_regex_paths=ignore_paths,
178162
ignore_order=True,
179-
custom_operators=[DeltaInfoOperator()],
180163
)
181164
if diff:
182165
aspect_changes[urn][aspect_name] = MCPAspectDiff.create(diff)

0 commit comments

Comments
 (0)