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(
421
421
return [], []
422
422
423
423
# Look for an existing session that can be extended
424
- session_start = None
425
- session_end = None
426
424
can_extend_session = False
427
425
existing_aggregated = None
428
426
old_window_to_delete = None
@@ -476,10 +474,6 @@ def process_window(
476
474
477
475
aggregated = self ._aggregate_value (current_value , value , timestamp_ms )
478
476
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
-
483
477
# Output intermediate results for aggregations
484
478
if aggregate :
485
479
updated_windows .append (
You can’t perform that action at this time.
0 commit comments