diff --git a/pyproject.toml b/pyproject.toml
index 6405d64d16..acee956e0b 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -22,7 +22,7 @@ dependencies = [
     "requests",
     "rich[jupyter]",
     "ruamel.yaml",
-    "sqlglot[rs]~=26.29.0",
+    "sqlglot[rs]~=26.30.0",
     "tenacity",
     "time-machine",
     "json-stream"
diff --git a/sqlmesh/core/dialect.py b/sqlmesh/core/dialect.py
index 279c9b6078..db77f0c461 100644
--- a/sqlmesh/core/dialect.py
+++ b/sqlmesh/core/dialect.py
@@ -346,12 +346,14 @@ def _parse_select(
     table: bool = False,
     parse_subquery_alias: bool = True,
     parse_set_operation: bool = True,
+    consume_pipe: bool = True,
 ) -> t.Optional[exp.Expression]:
     select = self.__parse_select(  # type: ignore
         nested=nested,
         table=table,
         parse_subquery_alias=parse_subquery_alias,
         parse_set_operation=parse_set_operation,
+        consume_pipe=consume_pipe,
     )
 
     if (
diff --git a/tests/core/test_macros.py b/tests/core/test_macros.py
index 7f4a417c46..c235430a69 100644
--- a/tests/core/test_macros.py
+++ b/tests/core/test_macros.py
@@ -234,7 +234,9 @@ def test_macro_var(macro_evaluator):
 
     # Check Snowflake-specific StagedFilePath / MacroVar behavior
     e = parse_one("select @x from @path, @y", dialect="snowflake")
+
     macro_evaluator.locals = {"x": parse_one("a"), "y": parse_one("t2")}
+    macro_evaluator.dialect = "snowflake"
 
     assert e.find(StagedFilePath) is not None
     assert macro_evaluator.transform(e).sql(dialect="snowflake") == "SELECT a FROM @path, t2"