在 Python 的 Apache Beam 中使用 OrFinally 定义自定义触发器的正确​​语法？

Correct syntax for defining custom trigger with OrFinally in Apache Beam in Python?

我正在尝试为滑动 window 定义一个自定义触发器，该触发器针对每个元素重复触发，但最终也会在水印结束时触发。我已经查看了将近一个小时的文档，但还没有找到任何示例:(.

        | beam.WindowInto(
            beam.window.SlidingWindows(60, 10),
            trigger= Repeatedly(
                (AfterCount(1), OrFinally(AfterWatermark()))
            ),
            accumulation_mode=beam.transforms.trigger.AccumulationMode.DISCARDING
        )

这就是我现在正在尝试的方法，显然这不起作用，但我对正确的语法非常迷茫。

你能试试像下面这样改变触发器吗

trigger=OrFinally(Repeatedly(AfterCount(1)), AfterWatermark()),
accumulation_mode=beam.transforms.trigger.AccumulationMode.DISCARDING