File tree Expand file tree Collapse file tree 1 file changed +0
-6
lines changed
quixstreams/dataframe/windows Expand file tree Collapse file tree 1 file changed +0
-6
lines changed Original file line number Diff line number Diff line change @@ -402,8 +402,6 @@ def process_window(
402402 return [], []
403403
404404 # Look for an existing session that can be extended
405- session_start = None
406- session_end = None
407405 can_extend_session = False
408406 existing_aggregated = None
409407 old_window_to_delete = None
@@ -457,10 +455,6 @@ def process_window(
457455
458456 aggregated = self ._aggregate_value (current_value , value , timestamp_ms )
459457
460- # By this point, session_start and session_end are guaranteed to be set
461- assert session_start is not None # noqa: S101
462- assert session_end is not None # noqa: S101
463-
464458 # Output intermediate results for aggregations
465459 if aggregate :
466460 updated_windows .append (
You can’t perform that action at this time.
0 commit comments