[BEAM-7127] Timer parameter not supported in timer callback

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.12.0
• Component/s: sdk-py-harness
• Labels: portability
• Assignee: Unassigned
• Reporter: Thomas Weise
• Created: 21/Apr/19 16:45
• Updated: 15/May/19 12:53

Description

Referencing the timer in its on_timer callback produces a recursive pickle error.  

@userstate.on_timer(timer_spec)
def process_timer(self, timer_1=beam.DoFn.TimerParam(timer_spec)):

Unit test: https://github.com/apache/beam/blob/cbe4dfbdbe5d0da5152568853ee5e17334dd1b54/sdks/python/apache_beam/transforms/userstate_test.py#L67 

Issue Links

• is related to: BEAM-7141 Expose kv and window parameters for on_timer
• relates to: BEAM-7141 Expose kv and window parameters for on_timer