File tree 1 file changed +2
-3
lines changed
bigframes/core/compile/polars
1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -360,6 +360,7 @@ def compile_window(self, node: nodes.WindowOpNode):
360
360
return df .with_columns ([agg_expr ])
361
361
362
362
else : # row-bounded window
363
+ assert isinstance (window .bounds , window_spec .RowsWindowBounds )
363
364
# Polars API semi-bounded, and any grouped rolling window challenging
364
365
# https://github.com/pola-rs/polars/issues/4799
365
366
# https://github.com/pola-rs/polars/issues/8976
@@ -383,9 +384,7 @@ def compile_window(self, node: nodes.WindowOpNode):
383
384
return pl .concat ([df , results ], how = "horizontal" )
384
385
385
386
386
- def _get_period (
387
- bounds : Union [window_spec .RowsWindowBounds , window_spec .RangeWindowBounds ]
388
- ) -> Optional [int ]:
387
+ def _get_period (bounds : window_spec .RowsWindowBounds ) -> Optional [int ]:
389
388
"""Returns None if the boundary is infinite."""
390
389
if bounds .start is None or bounds .end is None :
391
390
return None
You can’t perform that action at this time.
0 commit comments