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

Update BulkDispatchWorkflows activity

Browse source 
The BulkDispatchWorkflows.cs activity in Elsa.Workflows.Runtime module has been updated with some key changes: Added detailed description to the input element, introduced the dispatchedInstancesCount to accurately track the number of instances dispatched, and removed some unnecessary white spaces for improved readability.
This commit is contained in:
Sipke Schoorstra 2023-12-17 21:45:43 +01:00
parent 916256e9f6
commit 6db3cc99b5
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/modules/Elsa.Workflows.Runtime/Activities/BulkDispatchWorkflows.cs
View file

@ -68,7 +68,7 @@ public class BulkDispatchWorkflows : Activity
/// <summary>
/// The input to send to the workflows.
/// </summary>
[Input(Description = "The input to send to the workflows.")]
[Input(Description = """Additional input to send to the workflows being dispatched. The "Item" key is reserved and should not be used.""")]
public Input<IDictionary<string, object>?> Input { get; set; } = default!;
/// <summary>
@ -103,18 +103,20 @@ public class BulkDispatchWorkflows : Activity
await foreach (var item in items)
{
batch.Add(item);
if (batch.Count < batchSize)
if (batch.Count < batchSize)
continue;
await ProcessBatch(context, batch);
dispatchedInstancesCount += batch.Count;
batch.Clear();
}
// Process the last batch if it has any items.
if (batch.Count > 0)
{
await ProcessBatch(context, batch);
dispatchedInstancesCount += batch.Count;
}
context.SetProperty(DispatchedInstancesCountKey, dispatchedInstancesCount);
@ -140,12 +142,10 @@ public class BulkDispatchWorkflows : Activity
// Otherwise, we can complete immediately.
await context.CompleteActivityAsync();
}
// Cancelling children
}
private async Task ProcessBatch(ActivityExecutionContext context, List<object> items)
{
var tasks = items.Select(async item =>