Skip to content

Commit 141fd3c

Browse files
committed
Fix internal flume test failure due to a newly added test. (#35440)
1 parent 9f07d13 commit 141fd3c

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1270,7 +1270,8 @@ def test_sliding_windows(self):
12701270
assert_that(
12711271
ret,
12721272
equal_to([(0, [1, 2]), (0, [1, 2, 3, 4, 5]), (0, [3, 4, 5, 6, 7, 8]),
1273-
(0, [6, 7, 8, 9]), (0, [9])]))
1273+
(0, [6, 7, 8, 9]), (0, [9])],
1274+
lambda x, y: x[0] == y[0] and sorted(x[1]) == sorted(y[1])))
12741275

12751276
def test_windowing(self):
12761277
with self.create_pipeline() as p:

0 commit comments

Comments
 (0)