diff --git a/src/core/Elsa.Core/Services/Dispatch/Consumers/ExecuteWorkflowInstanceRequestConsumer.cs b/src/core/Elsa.Core/Services/Dispatch/Consumers/ExecuteWorkflowInstanceRequestConsumer.cs
index 3094caf4e..31575c202 100644
--- a/src/core/Elsa.Core/Services/Dispatch/Consumers/ExecuteWorkflowInstanceRequestConsumer.cs
+++ b/src/core/Elsa.Core/Services/Dispatch/Consumers/ExecuteWorkflowInstanceRequestConsumer.cs
@@ -12,7 +12,7 @@ namespace Elsa.Services.Dispatch.Consumers
 
         public async Task Handle(ExecuteWorkflowInstanceRequest message)
         {
-            await _workflowInstanceExecutor.ExecuteAsync(message.WorkflowInstanceId, message.ActivityId, new WorkflowInput(message.Input));
+            await _workflowInstanceExecutor.ExecuteAsync(message.WorkflowInstanceId, message.ActivityId, message.Input);
         }
     }
 }
\ No newline at end of file