diff --git a/src/core/Elsa.Core/Services/WorkflowQueue.cs b/src/core/Elsa.Core/Services/WorkflowQueue.cs index 7302f6602..c8e6e3bdc 100644 --- a/src/core/Elsa.Core/Services/WorkflowQueue.cs +++ b/src/core/Elsa.Core/Services/WorkflowQueue.cs @@ -23,7 +23,7 @@ namespace Elsa.Services } public async Task Enqueue(string workflowInstanceId, string activityId, CancellationToken cancellationToken = default) => - await _backgroundWorker.ScheduleTask(workflowInstanceId, async () => await RunWorkflowAsync(workflowInstanceId, activityId, cancellationToken), cancellationToken, Duration.FromMinutes(1)); + await _backgroundWorker.ScheduleTask(workflowInstanceId, async () => await RunWorkflowAsync(workflowInstanceId, activityId, cancellationToken), cancellationToken, Duration.FromMinutes(5)); private async ValueTask RunWorkflowAsync(string workflowInstanceId, string activityId, CancellationToken cancellationToken = default) { @@ -34,7 +34,7 @@ namespace Elsa.Services if (!ValidatePreconditions(workflowInstanceId, workflowInstance)) return; - _logger.LogDebug("Running {WorkflowInstanceId} with status {WorkflowStatus}.", workflowInstance!.WorkflowStatus); + _logger.LogDebug("Running {WorkflowInstanceId} with status {WorkflowStatus}.", workflowInstanceId, workflowInstance!.WorkflowStatus); var workflowDefinitionId = workflowInstance!.DefinitionId; var tenantId = workflowInstance.TenantId;