robertwb commented on a change in pull request #11314: [BEAM-9562] Send Timers over Data Channel as Elements URL: https://github.com/apache/beam/pull/11314#discussion_r406004352
########## File path: sdks/python/apache_beam/runners/worker/operations.pxd ########## @@ -92,7 +92,7 @@ cdef class DoOperation(Operation): cdef DoFnRunner dofn_runner cdef object tagged_receivers cdef object side_input_maps - cdef object user_state_context + cpdef public object user_state_context Review comment: Rather than making this public, I would add an `add_timer_info` method to this operation. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
