Skip to content

Commit

Permalink
Remove eager sync of timeouts when constructing Messages in Invocatio…
Browse files Browse the repository at this point in the history
…nHelper
  • Loading branch information
stidsborg committed Jul 31, 2024
1 parent 82ebf11 commit 3f5b774
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -376,10 +376,7 @@ public async Task<Messages> CreateMessages(FlowId flowId, ScheduleReInvocation s
var messages = new Messages(messageWriter, timeoutProvider, messagesPullerAndEmitter);

if (sync)
await Task.WhenAll(
timeoutProvider.PendingTimeouts(), //syncs local timeout cache inside the timeout provider
messages.Sync()
);
await messages.Sync();

return messages;
}
Expand Down

0 comments on commit 3f5b774

Please sign in to comment.