Skip to content

Commit 96042c8

Browse files
authored
Update taxi_streaming_pipeline_test.py
fix wrong_fn name
1 parent afdc42d commit 96042c8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

quests/dataflow_python/8b_Stream_Testing_Pipeline/lab/taxi_streaming_pipeline_test.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,8 @@ def test_windowing_behavior(self):
7878
# | TaxiCountTransform()
7979
# )
8080

81-
# assert_that(taxi_counts, equal_to(EXPECTED_RESULTS))
81+
# assert_that(taxi_counts, equal_to_per_window(EXPECTED_RESULTS), reify_windows=True) #corrected line.
8282

8383
if __name__ == '__main__':
8484
with open('testing.out', 'w') as f:
85-
main(f)
85+
main(f)

0 commit comments

Comments
 (0)