Build the set of (event_time, data, chunk_start) representing full output state.
(events: dict, assignments: dict)
| 357 | |
| 358 | |
| 359 | def _output_rows(events: dict, assignments: dict) -> set: |
| 360 | """Build the set of (event_time, data, chunk_start) representing full output state.""" |
| 361 | rows = set() |
| 362 | for _eid, (event_time, _flag, data) in events.items(): |
| 363 | cs = assignments[event_time] |
| 364 | rows.add((event_time, data, cs)) |
| 365 | return rows |
| 366 | |
| 367 | |
| 368 | def _compute_expected_diffs(old_rows: set, new_rows: set) -> set: |
no test coverage detected