diff --git a/sqlmesh/core/dialect.py b/sqlmesh/core/dialect.py index 1aa7ca839a..1d092cfbc0 100644 --- a/sqlmesh/core/dialect.py +++ b/sqlmesh/core/dialect.py @@ -315,16 +315,19 @@ 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 self.__parse_join(skip_join_token=skip_join_token, parse_bracket=parse_bracket, alias_tokens=alias_tokens) # type: ignore - join = self.__parse_join(skip_join_token=True) # type: ignore + join = self.__parse_join(skip_join_token=True, alias_tokens=alias_tokens) # type: ignore if method: join.set("method", method.text) if side: