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

Update TriggerIndexer.cs

Browse source
This commit is contained in:
Sipke Schoorstra 2022-03-07 15:11:03 +01:00
parent 1185a8e33a
commit 46d2d2b00b
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/runtime/Elsa.Runtime/Services/TriggerIndexer.cs
View file

@ -125,14 +125,14 @@ public class TriggerIndexer : ITriggerIndexer
// For each startable node, create triggers.
foreach (var node in startableNodes)
{
var triggers = await GetTriggersAsync(context, (IEventGenerator)node.Activity, cancellationToken);
var triggers = await GetTriggersAsync(context, node.Activity);
foreach (var trigger in triggers)
yield return trigger;
}
}
private async Task<IEnumerable<WorkflowTrigger>> GetTriggersAsync(WorkflowIndexingContext context, IActivity activity, CancellationToken cancellationToken)
private async Task<IEnumerable<WorkflowTrigger>> GetTriggersAsync(WorkflowIndexingContext context, IActivity activity)
{
// If the activity implements ITrigger, request its trigger data. Otherwise, create one trigger datum.
if (activity is ITrigger trigger)