File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2148,9 +2148,13 @@ def execute(
21482148 # terminal state (e.g. failed). This is a *new* rewind that
21492149 # the worker must short-circuit by building clean history.
21502150 # 2. executionCompleted is NOT present → the backend already
2151- # processed the RewindOrchestrationAction which removed
2152- # executionCompleted from history. This is a normal
2153- # post-rewind replay.
2151+ # processed the RewindOrchestrationAction and removed
2152+ # executionCompleted from the committed history. Here the
2153+ # executionRewound event in new_events acts as a "jump-start":
2154+ # it wakes the orchestration so that normal replay re-emits
2155+ # scheduleTask actions for the removed activities, causing the
2156+ # previously-failed work to rerun. No further rewrite is needed,
2157+ # so we fall through to the normal replay path below.
21542158 has_rewind_in_new = any (
21552159 e .HasField ("executionRewound" ) for e in new_events
21562160 )
You can’t perform that action at this time.
0 commit comments