Bugfix workflow execute dtmfailureexception

src/Dtmworkflow/Workflow.Imp.cs

@@ -81,6 +81,9 @@ internal async Task<byte[]> Process(WfFunc2 handler, byte[] data)
                 await this.Submit(res, err, default);
             }
 
+            if (err != null)
+                throw err;
+
             return res;
         }
 

tests/Dtmworkflow.Tests/WorkflowHttpTests.cs

@@ -62,7 +62,7 @@
             var gid = Guid.NewGuid().ToString("N");
 
             var handler = new Mock<WfFunc2>();
             handler.Setup(x => x.Invoke(It.IsAny<Workflow>(), It.IsAny<byte[]>())).Returns(Task.FromResult<byte[]>(null));
 
             wfgt.Register(wfName, handler.Object);
 
@@ -141,7 +141,7 @@
         }
 
         [Fact]
-        public async void Execute_Should_Return_Null_When_WfFunc2_ThrowDtmFailureException()
+        public async void Execute_Should_ThrowDtmFailureException_When_WfFunc2_ThrowDtmFailureException()
         {
             var factory = new Mock<IWorkflowFactory>();
             var httpClient = new Mock<IDtmClient>();
@@ -161,7 +161,7 @@
 
             var wfgt = new WorkflowGlobalTransaction(factory.Object, NullLoggerFactory.Instance);
 
-            var wfName = nameof(Execute_Should_Return_Null_When_WfFunc2_ThrowDtmFailureException);
+            var wfName = nameof(Execute_Should_ThrowDtmFailureException_When_WfFunc2_ThrowDtmFailureException);
             var gid = Guid.NewGuid().ToString("N");
 
             var handler = new Mock<WfFunc2>();
@@ -170,8 +170,7 @@
             wfgt.Register(wfName, handler.Object);
             var req = JsonSerializer.Serialize(new { userId = "1", amount = 30 });
 
-            var res = await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true);
-            Assert.Null(res);
+            await Assert.ThrowsAsync<DtmFailureException>(async () => await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true));
         }
 
         [Fact]
@@ -209,7 +208,7 @@
             wfgt.Register(wfName, handler);
             var req = JsonSerializer.Serialize(new { userId = "1", amount = 30 });
 
-            var res = await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true);
+            var res = await Assert.ThrowsAsync<DtmFailureException>(async () => await wfgt.Execute(wfName, gid, Encoding.UTF8.GetBytes(req), true));
 
             func.Verify(x => x.Invoke(It.IsAny<BranchBarrier>()), Times.Once);
         }
@@ -362,7 +361,7 @@
             Assert.Null(res);
         }
 
         private void SetupPrepareWorkflow(Mock<IDtmClient> httpClient, string status, string? result, List<DtmProgressDto> progressDtos = null)
         {
             var httpResp = new HttpResponseMessage(HttpStatusCode.OK);
             httpResp.Content = new StringContent(JsonSerializer.Serialize(