Thomas Weise created BEAM-7127:
----------------------------------
Summary: Timer parameter not supported in timer callback
Key: BEAM-7127
URL: https://issues.apache.org/jira/browse/BEAM-7127
Project: Beam
Issue Type: Bug
Components: sdk-py-harness
Affects Versions: 2.12.0
Reporter: Thomas Weise
Referencing the timer in its on_timer callback produces a recursive pickle
error.
{code:java}
@userstate.on_timer(timer_spec)
def process_timer(self, timer_1=beam.DoFn.TimerParam(timer_spec)):
{code}
Unit test:
[https://github.com/apache/beam/blob/cbe4dfbdbe5d0da5152568853ee5e17334dd1b54/sdks/python/apache_beam/transforms/userstate_test.py#L67]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
