Skip to content

Commit fb51d27

Browse files
committed
Rebench two failed tests.
1 parent 8f85812 commit fb51d27

2 files changed

Lines changed: 6 additions & 2 deletions

File tree

sdks/python/apache_beam/examples/complete/game/leader_board_test.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,10 @@ def test_leader_board_users(self):
6565
result = (
6666
self.create_data(p)
6767
| leader_board.CalculateUserScores(allowed_lateness=120))
68-
assert_that(result, equal_to([]))
68+
assert_that(
69+
result,
70+
equal_to([('user2_team2', 2), ('user3_team3', 8), ('user4_team3', 5),
71+
('user1_team1', 50)]))
6972

7073

7174
if __name__ == '__main__':

sdks/python/apache_beam/transforms/trigger_test.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -663,7 +663,8 @@ def format_result(k, vs):
663663
equal_to(
664664
list({
665665
'A-5': {1, 2, 3, 4, 5},
666-
# A-10, A-11 never emitted due to AfterCount(3) never firing.
666+
# A-10, A-11 emit on the closing of window [10, 19]
667+
'A-2': {10, 11},
667668
'B-4': {6, 7, 8, 9},
668669
'B-3': {10, 15, 16},
669670
}.items())))

0 commit comments

Comments
 (0)