Skip to content

Commit d70cc4c

Browse files
authored
Fixed returnInternalServerErrorOnFailure not working as expected (#1683)
* Fixed returnInternalServerErrorOnFailure parameter not being passed * Adding test code for returnInternalServerErrorOnFailure
1 parent be3554b commit d70cc4c

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

src/WebJobs.Extensions.DurableTask/ContextImplementations/DurableClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ async Task<HttpResponseMessage> IDurableOrchestrationClient.WaitForCompletionOrC
125125
async Task<IActionResult> IDurableOrchestrationClient.WaitForCompletionOrCreateCheckStatusResponseAsync(HttpRequest request, string instanceId, TimeSpan? timeout, TimeSpan? retryInterval, bool returnInternalServerErrorOnFailure)
126126
{
127127
HttpRequestMessage requestMessage = ConvertHttpRequestMessage(request);
128-
HttpResponseMessage responseMessage = await ((IDurableOrchestrationClient)this).WaitForCompletionOrCreateCheckStatusResponseAsync(requestMessage, instanceId, timeout, retryInterval);
128+
HttpResponseMessage responseMessage = await ((IDurableOrchestrationClient)this).WaitForCompletionOrCreateCheckStatusResponseAsync(requestMessage, instanceId, timeout, retryInterval, returnInternalServerErrorOnFailure);
129129
return ConvertHttpResponseMessage(responseMessage);
130130
}
131131

test/Common/DurableClientBaseTests.cs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -255,9 +255,17 @@ public async Task HttpRequest_HttpRequestMessage_ClientMethods_Identical()
255255
HttpResponseMessage netCoreResponse = (HttpResponseMessage)((ObjectResult)durableOrchestrationClient.CreateCheckStatusResponse(netCoreRequest, sampleId)).Value;
256256
await AssertHttpResponsesEqual(netFrameworkResponse, netCoreResponse);
257257

258+
netFrameworkResponse = durableOrchestrationClient.CreateCheckStatusResponse(netFrameworkRequest, sampleId, returnInternalServerErrorOnFailure: true);
259+
netCoreResponse = (HttpResponseMessage)((ObjectResult)durableOrchestrationClient.CreateCheckStatusResponse(netCoreRequest, sampleId, returnInternalServerErrorOnFailure: true)).Value;
260+
await AssertHttpResponsesEqual(netFrameworkResponse, netCoreResponse);
261+
258262
netFrameworkResponse = await durableOrchestrationClient.WaitForCompletionOrCreateCheckStatusResponseAsync(netFrameworkRequest, sampleId);
259263
netCoreResponse = (HttpResponseMessage)((ObjectResult)await durableOrchestrationClient.WaitForCompletionOrCreateCheckStatusResponseAsync(netCoreRequest, sampleId)).Value;
260264
await AssertHttpResponsesEqual(netFrameworkResponse, netCoreResponse);
265+
266+
netFrameworkResponse = await durableOrchestrationClient.WaitForCompletionOrCreateCheckStatusResponseAsync(netFrameworkRequest, sampleId, returnInternalServerErrorOnFailure: true);
267+
netCoreResponse = (HttpResponseMessage)((ObjectResult)await durableOrchestrationClient.WaitForCompletionOrCreateCheckStatusResponseAsync(netCoreRequest, sampleId, returnInternalServerErrorOnFailure: true)).Value;
268+
await AssertHttpResponsesEqual(netFrameworkResponse, netCoreResponse);
261269
}
262270

263271
private static async Task<HttpRequest> ConvertHttpRequestMessageAsync(HttpRequestMessage req)

0 commit comments

Comments
 (0)