-
Type:
Bug
-
Status: Open
-
Priority:
Major
-
Resolution: Unresolved
-
Affects Version/s: 2.12.0
-
Fix Version/s: None
-
Component/s: sdk-py-harness
-
Labels:
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)):