We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 62643db commit c5cb784Copy full SHA for c5cb784
sdks/python/apache_beam/runners/worker/operations.py
@@ -808,6 +808,7 @@ def __init__(
808
self.user_state_context = user_state_context
809
self.tagged_receivers = None # type: Optional[_TaggedReceivers]
810
# A mapping of timer tags to the input "PCollections" they come in on.
811
+ # Force clean rebuild
812
self.input_info = None # type: Optional[OpInputInfo]
813
self.scoped_timer_processing_state = None
814
if self.state_sampler:
0 commit comments