From 8675ab3d6ebd0860cfe49964eca98b504f93a145 Mon Sep 17 00:00:00 2001 From: Mark van Renswoude Date: Wed, 23 Nov 2022 12:58:31 +0100 Subject: [PATCH] Fixed exception in flow requests --- Tapeti.Flow/Default/FlowProvider.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Tapeti.Flow/Default/FlowProvider.cs b/Tapeti.Flow/Default/FlowProvider.cs index b203961..0ef8aa3 100644 --- a/Tapeti.Flow/Default/FlowProvider.cs +++ b/Tapeti.Flow/Default/FlowProvider.cs @@ -74,7 +74,7 @@ namespace Tapeti.Flow.Default internal async Task SendRequest(FlowContext context, object message, ResponseHandlerInfo responseHandlerInfo, string? convergeMethodName = null, bool convergeMethodTaskSync = false, bool store = true) { - if (context.FlowState == null) + if (!context.HasFlowStateAndLock) { await CreateNewFlowState(context); Debug.Assert(context.FlowState != null, "context.FlowState != null");