Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix(ingest): pin lookml liquid dep #12896

Merged
merged 2 commits into from
Mar 17, 2025
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions metadata-ingestion/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,11 @@
"lkml>=1.3.4",
*sqlglot_lib,
"GitPython>2",
"python-liquid",
# python-liquid 2 includes a bunch of breaking changes.
# See https://jg-rp.github.io/liquid/migration/
# Eventually we should fully upgrade to v2, but that will require
# us to drop Python 3.8 support first.
"python-liquid<2",
"deepmerge>=1.1.1",
}

Expand Down Expand Up @@ -712,7 +716,7 @@
"mariadb",
"redash",
"vertica",
"vertexai"
"vertexai",
]
if plugin
for dependency in plugins[plugin]
Expand Down
19 changes: 1 addition & 18 deletions metadata-ingestion/src/datahub/testing/mcp_diff.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
import yaml
from deepdiff import DeepDiff
from deepdiff.model import DiffLevel
from deepdiff.operator import BaseOperator
from typing_extensions import Literal

ReportType = Literal[
Expand Down Expand Up @@ -59,27 +58,12 @@ def __repr__(self):

@dataclasses.dataclass
class DeltaInfo:
"""Information about an MCP used to construct a diff delta.

In a separate class so it can be ignored by DeepDiff via MCPDeltaInfoOperator.
"""
"""Information about an MCP used to construct a diff delta."""

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


class DeltaInfoOperator(BaseOperator):
"""Warning: Doesn't seem to be working right now.
Ignored via an ignore path as an extra layer of defense.
"""

def __init__(self):
super().__init__(types=[DeltaInfo])

def give_up_diffing(self, *args: Any, **kwargs: Any) -> bool:
return True


AspectsByUrn = Dict[str, Dict[str, List[AspectForDiff]]]


Expand Down Expand Up @@ -176,7 +160,6 @@ def create(
t2=t2,
exclude_regex_paths=ignore_paths,
ignore_order=True,
custom_operators=[DeltaInfoOperator()],
)
if diff:
aspect_changes[urn][aspect_name] = MCPAspectDiff.create(diff)
Expand Down
Loading