diff --git a/pyproject.toml b/pyproject.toml index 0f9a9e2c3e..4c5faa2820 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -24,7 +24,7 @@ dependencies = [ "requests", "rich[jupyter]", "ruamel.yaml", - "sqlglot~=30.8.0", + "sqlglot~=30.9.0", "tenacity", "time-machine", "json-stream" diff --git a/sqlmesh/core/dialect.py b/sqlmesh/core/dialect.py index 94b8c2f2ad..cecb92b5f0 100644 --- a/sqlmesh/core/dialect.py +++ b/sqlmesh/core/dialect.py @@ -315,16 +315,23 @@ def _parse_with(self: Parser, skip_with_token: bool = False) -> t.Optional[exp.E def _parse_join( - self: Parser, skip_join_token: bool = False, parse_bracket: bool = False + self: Parser, + skip_join_token: bool = False, + parse_bracket: bool = False, + alias_tokens: t.Optional[t.Collection[TokenType]] = None, ) -> t.Optional[exp.Expr]: index = self._index method, side, kind = self._parse_join_parts() macro = _parse_matching_macro(self, "JOIN") if not macro: self._retreat(index) - return self.__parse_join(skip_join_token=skip_join_token, parse_bracket=parse_bracket) # type: ignore + return super(Parser, self)._parse_join( + skip_join_token=skip_join_token, + parse_bracket=parse_bracket, + alias_tokens=alias_tokens, + ) - join = self.__parse_join(skip_join_token=True) # type: ignore + join = super(Parser, self)._parse_join(skip_join_token=True, alias_tokens=alias_tokens) if method: join.set("method", method.text) if side: