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 @@ -421,8 +421,6 @@ def process_window(
421421 return [], []
422422
423423 # Look for an existing session that can be extended
424- session_start = None
425- session_end = None
426424 can_extend_session = False
427425 existing_aggregated = None
428426 old_window_to_delete = None
@@ -476,10 +474,6 @@ def process_window(
476474
477475 aggregated = self ._aggregate_value (current_value , value , timestamp_ms )
478476
479- # By this point, session_start and session_end are guaranteed to be set
480- assert session_start is not None # noqa: S101
481- assert session_end is not None # noqa: S101
482-
483477 # Output intermediate results for aggregations
484478 if aggregate :
485479 updated_windows .append (
You can’t perform that action at this time.
0 commit comments