fix check-point restore-time race in off-thread workflow event stream

2026-06-16 21:04:09 +08:00 · 2026-04-03 11:12:11 -07:00
parent 1f8078e496
commit 01a1939600
1 changed files with 0 additions and 4 deletions
@@ -287,10 +287,6 @@ internal sealed class StreamingRunEventStream : IRunEventStream
        {
            // Discard each event (including InternalCompletionSignals)
        }
-
-        // After clearing, signal the run loop to continue if needed
-        // The run loop will send a new completion signal when it finishes processing from the restored state
-        this.SignalInput();
    }

    public async ValueTask StopAsync()