Skip to content

Commit 13552f2

Browse files
committed
Chore: upgrade to sqlglot 11.6 and clean up example project paths
1 parent 3ce6409 commit 13552f2

8 files changed

Lines changed: 8 additions & 21 deletions

File tree

examples/sushi/models/items.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44

55
import numpy as np
66
import pandas as pd
7+
from helper import iter_dates # type: ignore
78
from sqlglot.expressions import to_column
89

9-
from examples.sushi.helper import iter_dates
1010
from sqlmesh import ExecutionContext, model
1111
from sqlmesh.core.model import IncrementalByTimeRangeKind
1212
from sqlmesh.utils.date import to_ds

examples/sushi/models/order_items.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44

55
import numpy as np
66
import pandas as pd
7+
from helper import iter_dates # type: ignore
78
from sqlglot.expressions import to_column
89

9-
from examples.sushi.helper import iter_dates
1010
from sqlmesh import ExecutionContext, model
1111
from sqlmesh.core.model import IncrementalByTimeRangeKind
1212
from sqlmesh.utils.date import to_ds

examples/sushi/models/orders.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@
33
from datetime import datetime, timedelta
44

55
import pandas as pd
6+
from helper import iter_dates # type: ignore
67

7-
from examples.sushi.helper import iter_dates
88
from sqlmesh import ExecutionContext, model
99
from sqlmesh.core.model import IncrementalByTimeRangeKind
1010
from sqlmesh.utils.date import to_ds

examples/wursthall/models/db/order_f.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
import numpy as np
66
import pandas as pd
7+
from models.src.shared import DATA_START_DATE_STR, set_seed # type: ignore
78

8-
from examples.wursthall.models.src.shared import DATA_START_DATE_STR, set_seed
99
from sqlmesh import ExecutionContext, model
1010
from sqlmesh.core.model import IncrementalByTimeRangeKind, TimeColumn
1111
from sqlmesh.utils.date import to_ds

examples/wursthall/models/src/customer_details.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,12 +5,8 @@
55

66
import pandas as pd
77
from faker import Faker
8+
from models.src.shared import DATA_START_DATE_STR, iter_dates, set_seed # type: ignore
89

9-
from examples.wursthall.models.src.shared import (
10-
DATA_START_DATE_STR,
11-
iter_dates,
12-
set_seed,
13-
)
1410
from sqlmesh import model
1511
from sqlmesh.core.model import IncrementalByTimeRangeKind, TimeColumn
1612

examples/wursthall/models/src/order_item_details.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,8 @@
66
import numpy as np
77
import pandas as pd
88
from faker import Faker
9+
from models.src.shared import DATA_START_DATE_STR, iter_dates, set_seed # type: ignore
910

10-
from examples.wursthall.models.src.shared import (
11-
DATA_START_DATE_STR,
12-
iter_dates,
13-
set_seed,
14-
)
1511
from sqlmesh import ExecutionContext, model
1612
from sqlmesh.core.model import IncrementalByTimeRangeKind, TimeColumn
1713
from sqlmesh.utils.date import to_ds

setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@
4343
"requests",
4444
"rich",
4545
"ruamel.yaml",
46-
"sqlglot~=11.5.7",
46+
"sqlglot~=11.6.1",
4747
"fsspec",
4848
],
4949
extras_require={

sqlmesh/core/dialect.py

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -418,16 +418,11 @@ def parse(sql: str, default_dialect: str | None = None) -> t.List[exp.Expression
418418
chunks[-1][0].append(token)
419419

420420
expressions: t.List[exp.Expression] = []
421-
sql_lines = None
422421

423422
for chunk, is_jinja in chunks:
424423
if is_jinja:
425424
start, *_, end = chunk
426-
sql_lines = sql_lines or sql.split("\n")
427-
lines = sql_lines[start.line - 1 : end.line]
428-
lines[0] = lines[0][start.col - 1 :]
429-
lines[-1] = lines[-1][: end.col + len(end.text) - 1]
430-
segment = "\n".join(lines)
425+
segment = sql[start.start : end.end + 1]
431426
variables = [
432427
exp.Literal.string(var)
433428
for var in find_undeclared_variables(ENVIRONMENT.parse(segment))

0 commit comments

Comments
 (0)