Skip to content

Commit bafb14f

Browse files
reimplemente poalrs fallback
1 parent 8e0bde8 commit bafb14f

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

bigframes/session/polars_executor.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -105,12 +105,12 @@ def execute(
105105
if not self._can_execute(plan):
106106
return None
107107
# Note: Ignoring ordered flag, as just executing totally ordered is fine.
108-
# try:
109-
lazy_frame: pl.LazyFrame = self._compiler.compile(
110-
array_value.ArrayValue(plan).node
111-
)
112-
# except Exception:
113-
# return None
108+
try:
109+
lazy_frame: pl.LazyFrame = self._compiler.compile(
110+
array_value.ArrayValue(plan).node
111+
)
112+
except Exception:
113+
return None
114114
if peek is not None:
115115
lazy_frame = lazy_frame.limit(peek)
116116
pa_table = lazy_frame.collect().to_arrow()

0 commit comments

Comments
 (0)