(evts)
| 902 | """ |
| 903 | |
| 904 | def compute_expected(evts): |
| 905 | assignments = _compute_chunk_assignments(evts) |
| 906 | chunk_counts: dict = {} |
| 907 | for event_time, cs in assignments.items(): |
| 908 | if cs is not None and cs > 10: |
| 909 | chunk_counts[cs] = chunk_counts.get(cs, 0) + 1 |
| 910 | return {(cs, cnt) for cs, cnt in chunk_counts.items()} |
| 911 | |
| 912 | def pipeline(t): |
| 913 | iterated = _build_chunk_propagation_pipeline(t) |
no test coverage detected