GitHub-Mirror/Tapeti
1
0
Fork 0
mirror of synced 2024-11-05 02:59:16 +00:00
Code Issues Projects Releases Wiki Activity

Fix for exception "Neither Store nor Delete are called for the state of the current flow" with parallel requests

Browse Source
This commit is contained in:
Mark van Renswoude 2018-12-19 15:53:56 +01:00
parent aa5eb4371c
commit ab03b38e6c
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
Tapeti.Flow/Default/FlowMessageMiddleware.cs
View File

@ -25,6 +25,9 @@ namespace Tapeti.Flow.Default
await CallConvergeMethod(context, await CallConvergeMethod(context,
flowContext.ContinuationMetadata.ConvergeMethodName, flowContext.ContinuationMetadata.ConvergeMethodName,
flowContext.ContinuationMetadata.ConvergeMethodSync); flowContext.ContinuationMetadata.ConvergeMethodSync);
else if (flowContext.FlowState.Continuations.Count > 0)
// This is a parallel flow waiting for other continuations, always store the state
await flowContext.Store();
} }
else else
await next(); await next();