SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Improve RunWorkflowJob to reschedule in case of slow DB call to save workflow instance

Browse source
This commit is contained in:
Sipke Schoorstra 2020-12-05 11:14:24 +01:00
parent 4f2233d980
commit 0cdd46f8ca
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/activities/Elsa.Activities.Timers/Jobs/RunWorkflowJob.cs
View file

@ -49,7 +49,11 @@ namespace Elsa.Activities.Timers.Jobs
if (workflowInstance == null)
{
_logger.LogWarning("Could not run Workflow instance with ID {WorkflowInstanceId} because it appears not yet to be persisted in the database. Skipping this round.", workflowInstanceId);
_logger.LogWarning("Could not run Workflow instance with ID {WorkflowInstanceId} because it appears not yet to be persisted in the database. Rescheduling.", workflowInstanceId);
var trigger = context.Trigger;
await context.Scheduler.UnscheduleJob(trigger.Key, cancellationToken);
var newTrigger = trigger.GetTriggerBuilder().StartAt(trigger.StartTimeUtc.AddSeconds(10)).Build();
await context.Scheduler.ScheduleJob(newTrigger, cancellationToken);
return;
}