Serialize Host Stopping Event in ActivityShim (#2178)

release_notes.md

@@ -0,0 +1,2 @@
+## Bug Fixes
+- Correctly Serialize HostStoppingEvent in ActivityShim (https://github.com/Azure/azure-functions-durable-extension/pull/2178)

src/WebJobs.Extensions.DurableTask/Listener/TaskActivityShim.cs

@@ -83,6 +83,7 @@ public override async Task<string> RunAsync(TaskContext context, string rawInput
                         taskEventId: this.taskEventId);
 
                     return serializedOutput;
+                case WrappedFunctionResult.FunctionResultStatus.FunctionsHostStoppingError:
                 case WrappedFunctionResult.FunctionResultStatus.FunctionsRuntimeError:
                     this.config.TraceHelper.FunctionAborted(
                         this.config.Options.HubName,
@@ -121,7 +122,11 @@ public override async Task<string> RunAsync(TaskContext context, string rawInput
                             $"Activity function '{this.activityName}' failed: {exceptionToReport.Message}",
                             Utils.SerializeCause(exceptionToReport, this.config.ErrorDataConverter));
                 default:
-                    throw new InvalidOperationException($"{nameof(TaskActivityShim.RunAsync)} does not handle the function execution status {result.ExecutionStatus}.");
+                    // we throw a TaskFailureException to ensure deserialization is possible.
+                    var innerException = new Exception($"{nameof(TaskActivityShim.RunAsync)} does not handle the function execution status {result.ExecutionStatus}.");
+                    throw new TaskFailureException(
+                            $"Activity function '{this.activityName}' failed: {innerException}",
+                            Utils.SerializeCause(innerException, this.config.ErrorDataConverter));
             }
         }