Reduce allowed lateness in FixedWindows from 10 to 2 seconds

apache · Mar 9, 2025 · c277671 · c277671
1 parent dfc45f0
commit c277671
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/examples/snippets/snippets_test.py b/sdks/python/apache_beam/examples/snippets/snippets_test.py
@@ -1153,7 +1153,7 @@ def test_model_composite_triggers(self):
           pcollection | WindowInto(
               FixedWindows(1 * 60),
               trigger=AfterWatermark(late=AfterProcessingTime(10 * 60)),
-              allowed_lateness=10,
+              allowed_c=2,
               accumulation_mode=AccumulationMode.DISCARDING)
           # [END model_composite_triggers]
           | 'group' >> beam.GroupByKey()