Command reordering in Core

src/Temporalio/Worker/TemporalWorker.cs

@@ -89,8 +89,7 @@ public TemporalWorker(IWorkerClient client, TemporalWorkerOptions options)
                     OnTaskStarting: options.OnTaskStarting,
                     OnTaskCompleted: options.OnTaskCompleted,
                     RuntimeMetricMeter: MetricMeter,
-                    WorkerLevelFailureExceptionTypes: options.WorkflowFailureExceptionTypes,
-                    DisableCompletionCommandReordering: options.DisableWorkflowCompletionCommandReordering));
+                    WorkerLevelFailureExceptionTypes: options.WorkflowFailureExceptionTypes));
             }
         }
 

src/Temporalio/Worker/TemporalWorkerOptions.cs

@@ -297,15 +297,6 @@ public TemporalWorkerOptions()
         internal Func<WorkflowInstanceDetails, IWorkflowInstance> WorkflowInstanceFactory { get; set; } =
             DefaultWorkflowInstanceFactory;
 
-        /// <summary>
-        /// Gets or sets a value indicating whether the workflow completion command reordering will
-        /// apply.
-        /// </summary>
-        /// <remarks>
-        /// This is visible for testing only.
-        /// </remarks>
-        internal bool DisableWorkflowCompletionCommandReordering { get; set; }
-
         /// <summary>
         /// Add the given delegate with <see cref="ActivityAttribute" /> as an activity. This is
         /// usually a method reference.

src/Temporalio/Worker/WorkflowInstance.cs

@@ -68,7 +68,6 @@ internal class WorkflowInstance : TaskScheduler, IWorkflowInstance, IWorkflowCon
         private readonly Action<WorkflowInstance> onTaskStarting;
         private readonly Action<WorkflowInstance, Exception?> onTaskCompleted;
         private readonly IReadOnlyCollection<Type>? workerLevelFailureExceptionTypes;
-        private readonly bool disableCompletionCommandReordering;
         private readonly Handlers inProgressHandlers = new();
         private WorkflowActivationCompletion? completion;
         // Will be set to null after last use (i.e. when workflow actually started)
@@ -190,7 +189,6 @@ public WorkflowInstance(WorkflowInstanceDetails details)
             Random = new(details.Start.RandomnessSeed);
             TracingEventsEnabled = !details.DisableTracingEvents;
             workerLevelFailureExceptionTypes = details.WorkerLevelFailureExceptionTypes;
-            disableCompletionCommandReordering = details.DisableCompletionCommandReordering;
         }
 
         /// <summary>
@@ -580,8 +578,8 @@ public WorkflowActivationCompletion Activate(WorkflowActivation act)
                     }
                 }
 
-                // Maybe apply workflow completion command reordering logic
-                ApplyCompletionCommandReordering(act, completion, out var workflowComplete);
+                // Maybe apply legacy workflow completion command reordering logic
+                ApplyLegacyCompletionCommandReordering(act, completion, out var workflowComplete);
 
                 // Log warnings if we have completed
                 if (workflowComplete && !IsReplaying)
@@ -1425,20 +1423,11 @@ private string GetStackTrace()
             }).Where(s => !string.IsNullOrEmpty(s)).Select(s => $"Task waiting at:\n{s}"));
         }
 
-        private void ApplyCompletionCommandReordering(
+        private void ApplyLegacyCompletionCommandReordering(
             WorkflowActivation act,
             WorkflowActivationCompletion completion,
             out bool workflowComplete)
         {
-            // In earlier versions of the SDK we allowed commands to be sent after workflow
-            // completion. These ended up being removed effectively making the result of the
-            // workflow function mean any other later coroutine commands be ignored. To match
-            // Go/Java, we are now going to move workflow completion to the end so that
-            // same-task-post-completion commands are still accounted for.
-            //
-            // Note this only applies for successful activations that don't have completion
-            // reordering disabled and that are either not replaying or have the flag set.
-
             // Find the index of the completion command
             var completionCommandIndex = -1;
             if (completion.Successful != null)
@@ -1459,21 +1448,22 @@ private void ApplyCompletionCommandReordering(
             }
             workflowComplete = completionCommandIndex >= 0;
 
-            // This only applies for successful activations that have a completion not at the end,
-            // don't have completion reordering disabled, and that are either not replaying or have
-            // the flag set.
+            // In a previous version of .NET, if this was a successful activation completion with
+            // a completion command not at the end, we'd reorder it to move at the end. However,
+            // this logic has now moved to core and become more robust. Therefore, we only apply
+            // this logic if we're replaying and flag is present so that workflows/histories that
+            // were created after this .NET flag but before the core flag still work.
             if (completion.Successful == null ||
                 completionCommandIndex == -1 ||
                 completionCommandIndex == completion.Successful.Commands.Count - 1 ||
-                disableCompletionCommandReordering ||
-                (IsReplaying && !act.AvailableInternalFlags.Contains(
-                    (uint)WorkflowLogicFlag.ReorderWorkflowCompletion)))
+                !IsReplaying ||
+                !act.AvailableInternalFlags.Contains((uint)WorkflowLogicFlag.ReorderWorkflowCompletion))
             {
                 return;
             }
 
-            // Now we know the completion is in the wrong spot and we're on a newer SDK, so set the
-            // SDK flag and move it
+            // Now we know that we're replaying w/ the flag set and the completion in the wrong
+            // spot, so set the SDK flag and move it
             completion.Successful.UsedInternalFlags.Add((uint)WorkflowLogicFlag.ReorderWorkflowCompletion);
             var compCmd = completion.Successful.Commands[completionCommandIndex];
             completion.Successful.Commands.RemoveAt(completionCommandIndex);

src/Temporalio/Worker/WorkflowInstanceDetails.cs

@@ -26,9 +26,6 @@ namespace Temporalio.Worker
     /// <param name="OnTaskCompleted">Callback for every instance task complete.</param>
     /// <param name="RuntimeMetricMeter">Lazy runtime-level metric meter.</param>
     /// <param name="WorkerLevelFailureExceptionTypes">Failure exception types at worker level.</param>
-    /// <param name="DisableCompletionCommandReordering">
-    /// Whether to disable completion command reordering.
-    /// </param>
     internal record WorkflowInstanceDetails(
         string Namespace,
         string TaskQueue,
@@ -44,6 +41,5 @@ internal record WorkflowInstanceDetails(
         Action<WorkflowInstance> OnTaskStarting,
         Action<WorkflowInstance, Exception?> OnTaskCompleted,
         Lazy<MetricMeter> RuntimeMetricMeter,
-        IReadOnlyCollection<Type>? WorkerLevelFailureExceptionTypes,
-        bool DisableCompletionCommandReordering);
+        IReadOnlyCollection<Type>? WorkerLevelFailureExceptionTypes);
 }

src/Temporalio/Worker/WorkflowReplayer.cs

@@ -173,8 +173,7 @@ public WorkflowHistoryRunner(WorkflowReplayerOptions options, bool throwOnReplay
                             OnTaskStarting: options.OnTaskStarting,
                             OnTaskCompleted: options.OnTaskCompleted,
                             RuntimeMetricMeter: new(() => runtime.MetricMeter),
-                            WorkerLevelFailureExceptionTypes: options.WorkflowFailureExceptionTypes,
-                            DisableCompletionCommandReordering: options.DisableWorkflowCompletionCommandReordering),
+                            WorkerLevelFailureExceptionTypes: options.WorkflowFailureExceptionTypes),
                         (runId, removeFromCache) => SetResult(removeFromCache));
                 }
                 catch

src/Temporalio/Worker/WorkflowReplayerOptions.cs

@@ -128,15 +128,6 @@ public class WorkflowReplayerOptions : ICloneable
         internal Func<WorkflowInstanceDetails, IWorkflowInstance> WorkflowInstanceFactory { get; set; } =
             TemporalWorkerOptions.DefaultWorkflowInstanceFactory;
 
-        /// <summary>
-        /// Gets or sets a value indicating whether the workflow completion command reordering will
-        /// apply.
-        /// </summary>
-        /// <remarks>
-        /// This is visible for testing only.
-        /// </remarks>
-        internal bool DisableWorkflowCompletionCommandReordering { get; set; }
-
         /// <summary>
         /// Add the given type as a workflow.
         /// </summary>

src/Temporalio/Worker/WorkflowWorker.cs

@@ -283,8 +283,7 @@ private IWorkflowInstance CreateInstance(WorkflowActivation act)
                     OnTaskStarting: options.OnTaskStarting,
                     OnTaskCompleted: options.OnTaskCompleted,
                     RuntimeMetricMeter: options.RuntimeMetricMeter,
-                    WorkerLevelFailureExceptionTypes: options.WorkerLevelFailureExceptionTypes,
-                    DisableCompletionCommandReordering: options.DisableCompletionCommandReordering));
+                    WorkerLevelFailureExceptionTypes: options.WorkerLevelFailureExceptionTypes));
         }
     }
 }

src/Temporalio/Worker/WorkflowWorkerOptions.cs

@@ -21,6 +21,5 @@ internal record WorkflowWorkerOptions(
         Action<WorkflowInstance> OnTaskStarting,
         Action<WorkflowInstance, Exception?> OnTaskCompleted,
         Lazy<MetricMeter> RuntimeMetricMeter,
-        IReadOnlyCollection<Type>? WorkerLevelFailureExceptionTypes,
-        bool DisableCompletionCommandReordering);
+        IReadOnlyCollection<Type>? WorkerLevelFailureExceptionTypes);
 }

tests/Temporalio.Tests/TestUtils.cs

@@ -4,18 +4,17 @@ namespace Temporalio.Tests;
 using System.Collections.Generic;
 using System.Net;
 using System.Net.Sockets;
+using System.Runtime.CompilerServices;
 using Microsoft.Extensions.Logging;
 using Temporalio.Client;
 using Temporalio.Exceptions;
 using Temporalio.Runtime;
 
 public static class TestUtils
 {
-    public static string CallerFilePath(
-        [System.Runtime.CompilerServices.CallerFilePath] string? callerPath = null)
-    {
-        return callerPath ?? throw new ArgumentException("Unable to find caller path");
-    }
+    public static string ReadAllFileText(
+        string relativePath, [CallerFilePath] string sourceFilePath = "") =>
+        File.ReadAllText(Path.Join(sourceFilePath, "..", relativePath));
 
     public static int FreePort()
     {