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(
402
402
return [], []
403
403
404
404
# Look for an existing session that can be extended
405
- session_start = None
406
- session_end = None
407
405
can_extend_session = False
408
406
existing_aggregated = None
409
407
old_window_to_delete = None
@@ -457,10 +455,6 @@ def process_window(
457
455
458
456
aggregated = self ._aggregate_value (current_value , value , timestamp_ms )
459
457
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
-
464
458
# Output intermediate results for aggregations
465
459
if aggregate :
466
460
updated_windows .append (
You can’t perform that action at this time.
0 commit comments