diff --git a/src/activities/Elsa.Activities.Http/Middleware/HttpEndpointMiddleware.cs b/src/activities/Elsa.Activities.Http/Middleware/HttpEndpointMiddleware.cs
index f32b1294f..816dfe6db 100644
--- a/src/activities/Elsa.Activities.Http/Middleware/HttpEndpointMiddleware.cs
+++ b/src/activities/Elsa.Activities.Http/Middleware/HttpEndpointMiddleware.cs
@@ -115,7 +115,7 @@ namespace Elsa.Activities.Http.Middleware
             else
             {
                 await workflowLaunchpad.ExecutePendingWorkflowAsync(pendingWorkflow, inputModel, cancellationToken);
-                pendingWorkflowInstance = await workflowInstanceStore.FindByIdAsync(pendingWorkflow.WorkflowInstanceId);
+                pendingWorkflowInstance = await workflowInstanceStore.FindByIdAsync(pendingWorkflow.WorkflowInstanceId, cancellationToken);
 
                 if (pendingWorkflowInstance is not null
                     && pendingWorkflowInstance.WorkflowStatus == Elsa.Models.WorkflowStatus.Faulted
diff --git a/src/core/Elsa.Core/Activities/Primitives/Correlate/Correlate.cs b/src/core/Elsa.Core/Activities/Workflows/Correlate/Correlate.cs
similarity index 100%
rename from src/core/Elsa.Core/Activities/Primitives/Correlate/Correlate.cs
rename to src/core/Elsa.Core/Activities/Workflows/Correlate/Correlate.cs
diff --git a/src/core/Elsa.Core/Activities/Primitives/Correlate/CorrelateBuilderExtensions.cs b/src/core/Elsa.Core/Activities/Workflows/Correlate/CorrelateBuilderExtensions.cs
similarity index 100%
rename from src/core/Elsa.Core/Activities/Primitives/Correlate/CorrelateBuilderExtensions.cs
rename to src/core/Elsa.Core/Activities/Workflows/Correlate/CorrelateBuilderExtensions.cs