I am experimenting with state / timers in Python. As I look at the DoFnProcessParams[1], I see that it's possible for a DoFn to receive several arguments (e.g. Timers, Side Inputs, etc). Also the Watermark via WatermarkReporterParam.
I see that this parameter is not handled by runners when filling up the arguments for a DoFn[2][3]. So, as far as I can tell, DoFns are not currently able to get the watermark. Is this a bug, or is it intentional? Perhaps there's another way to find out the watermark for a DoFn? Best -P. [1] https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/core.py#L381-L390 [2] https://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/common.py#L477-L488 [3] https://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/common.py#L605-L620
