Skip to content

Commit 3a235e8

Browse files
committed
Fixed sync-bug when creating new function
1 parent 15932c1 commit 3a235e8

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Core/Cleipnir.ResilientFunctions/CoreRuntime/Invocation/InvocationHelper.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,7 @@ public Messages CreateMessages(
409409
ScheduleReInvocation scheduleReInvocation,
410410
Func<bool> isWorkflowRunning,
411411
Effect effect,
412-
IReadOnlyList<StoredMessage> initialMessages)
412+
IReadOnlyList<StoredMessage>? initialMessages)
413413
{
414414
var messageWriter = new MessageWriter(storedId, _functionStore, Serializer, scheduleReInvocation);
415415
var registeredTimeouts = new RegisteredTimeouts(storedId, _functionStore.TimeoutStore, effect);

Core/Cleipnir.ResilientFunctions/CoreRuntime/Invocation/Invoker.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ await _invocationHelper.PersistFunctionInStore(
238238
ScheduleRestart,
239239
isWorkflowRunning: () => !isWorkflowRunningDisposable.Disposed,
240240
effect,
241-
initialState == null ? [] : _invocationHelper.MapInitialMessages(initialState.Messages)
241+
initialState == null ? null : _invocationHelper.MapInitialMessages(initialState.Messages)
242242
);
243243

244244
var correlations = _invocationHelper.CreateCorrelations(flowId);

0 commit comments

Comments
 (0)