diff --git a/samples/aspnet/Elsa.Samples.AspNet.BatchProcessing/Workflows/OrderBatchProcessor.cs b/samples/aspnet/Elsa.Samples.AspNet.BatchProcessing/Workflows/OrderBatchProcessor.cs
index 0ad44abf9..e43fbbfb8 100644
--- a/samples/aspnet/Elsa.Samples.AspNet.BatchProcessing/Workflows/OrderBatchProcessor.cs
+++ b/samples/aspnet/Elsa.Samples.AspNet.BatchProcessing/Workflows/OrderBatchProcessor.cs
@@ -4,6 +4,7 @@ using Elsa.Samples.AspNet.BatchProcessing.Models;
 using Elsa.Workflows;
 using Elsa.Workflows.Activities;
 using Elsa.Workflows.Contracts;
+using Elsa.Workflows.Memory;
 
 namespace Elsa.Samples.AspNet.BatchProcessing.Workflows;
 
@@ -27,7 +28,14 @@ public class OrderBatchProcessor : WorkflowBase
                 },
                 new ParallelForEach<Order>
                 {
-                    Items = new(orders) 
+                    Items = new(orders),
+                    Body = new Sequence
+                    {
+                        Activities =
+                        {
+                            new WriteLine(context => $"Processing order {context.GetVariable<Order>("CurrentValue")!.Id}"),
+                        }
+                    }
                 },
                 new WriteLine("Done!")
             }
diff --git a/src/modules/Elsa.Workflows.Core/Contexts/ActivityExecutionContext.cs b/src/modules/Elsa.Workflows.Core/Contexts/ActivityExecutionContext.cs
index 9583fbc20..65d4e7e75 100644
--- a/src/modules/Elsa.Workflows.Core/Contexts/ActivityExecutionContext.cs
+++ b/src/modules/Elsa.Workflows.Core/Contexts/ActivityExecutionContext.cs
@@ -278,6 +278,7 @@ public partial class ActivityExecutionContext : IExecutionContext
         {
             if (completionCallback != null)
             {
+                Tag = options?.Tag;
                 var completedContext = new ActivityCompletedContext(this, this);
                 await completionCallback(completedContext);
             }