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

Pass composite input to first scheduled child

Browse source
This commit is contained in:
Sipke Schoorstra 2020-12-04 21:41:52 +01:00
parent e00d41e0cf
commit 4f2233d980
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/core/Elsa.Abstractions/Services/Activity.cs
View file

@ -42,8 +42,8 @@ namespace Elsa.Services
protected OutputResult Output(object? output) => new(output);
protected SuspendResult Suspend() => new();
protected ScheduleActivitiesResult Schedule(params string[] activityIds) => new(activityIds);
protected ScheduleActivitiesResult Schedule(IEnumerable<string> activityIds, object input) => new(activityIds, input);
protected ScheduleActivitiesResult Schedule(string activityId, object input) => Schedule(new[] { activityId }, input);
protected ScheduleActivitiesResult Schedule(IEnumerable<string> activityIds, object? input) => new(activityIds, input);
protected ScheduleActivitiesResult Schedule(string activityId, object? input) => Schedule(new[] { activityId }, input);
protected ScheduleActivitiesResult Schedule(IEnumerable<ScheduledActivity> activities) => new(activities);
protected PostScheduleActivitiesResult PostSchedule(params string[] activityIds) => new(activityIds);
protected CombinedResult Combine(IEnumerable<IActivityExecutionResult> results) => new(results);

2
src/core/Elsa.Abstractions/Services/CompositeActivity.cs
View file

@ -26,7 +26,7 @@ namespace Elsa.Services
var startActivities = compositeActivityBlueprint.GetStartActivities().Select(x => x.Id).ToList();
context.WorkflowExecutionContext.PostScheduleActivity(Id);
IsScheduled = true;
return Schedule(startActivities, null!);
return Schedule(startActivities, context.Input);
}
protected virtual IActivityExecutionResult Complete(ActivityExecutionContext context) => Done();