Skip to content

Commit 1e04ffe

Browse files
authored
fix: put limit on lru cache (#4867)
1 parent 445645b commit 1e04ffe

File tree

4 files changed

+6
-6
lines changed

4 files changed

+6
-6
lines changed

sqlmesh/core/dialect.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1175,7 +1175,7 @@ def set_default_catalog(
11751175
return table
11761176

11771177

1178-
@lru_cache(maxsize=None)
1178+
@lru_cache(maxsize=16384)
11791179
def normalize_model_name(
11801180
table: str | exp.Table | exp.Column,
11811181
default_catalog: t.Optional[str],

sqlmesh/core/macros.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1558,6 +1558,6 @@ def _convert_sql(v: t.Any, dialect: DialectType) -> t.Any:
15581558
return v
15591559

15601560

1561-
@lru_cache(maxsize=1028)
1561+
@lru_cache(maxsize=16384)
15621562
def _cache_convert_sql(v: t.Any, dialect: DialectType, t: type) -> t.Any:
15631563
return _convert_sql(v, dialect)

sqlmesh/core/snapshot/definition.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1905,7 +1905,7 @@ def missing_intervals(
19051905
return missing
19061906

19071907

1908-
@lru_cache(maxsize=None)
1908+
@lru_cache(maxsize=16384)
19091909
def expand_range(start_ts: int, end_ts: int, interval_unit: IntervalUnit) -> t.List[int]:
19101910
croniter = interval_unit.croniter(start_ts)
19111911
timestamps = [start_ts]
@@ -1922,7 +1922,7 @@ def expand_range(start_ts: int, end_ts: int, interval_unit: IntervalUnit) -> t.L
19221922
return timestamps
19231923

19241924

1925-
@lru_cache(maxsize=None)
1925+
@lru_cache(maxsize=16384)
19261926
def compute_missing_intervals(
19271927
interval_unit: IntervalUnit,
19281928
intervals: t.Tuple[Interval, ...],
@@ -1984,7 +1984,7 @@ def compute_missing_intervals(
19841984
return sorted(missing)
19851985

19861986

1987-
@lru_cache(maxsize=None)
1987+
@lru_cache(maxsize=16384)
19881988
def inclusive_exclusive(
19891989
start: TimeLike,
19901990
end: TimeLike,

sqlmesh/utils/cron.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
from sqlmesh.utils.date import TimeLike, now, to_datetime
1111

1212

13-
@lru_cache(maxsize=None)
13+
@lru_cache(maxsize=16384)
1414
def interval_seconds(cron: str) -> int:
1515
"""Computes the interval seconds of a cron statement if it is deterministic.
1616

0 commit comments

Comments
 (0)