diff --git a/src/core/Elsa.Abstractions/Services/Activity.cs b/src/core/Elsa.Abstractions/Services/Activity.cs
index 2ad4d5c00..84c7b0fd7 100644
--- a/src/core/Elsa.Abstractions/Services/Activity.cs
+++ b/src/core/Elsa.Abstractions/Services/Activity.cs
@@ -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);
diff --git a/src/core/Elsa.Abstractions/Services/CompositeActivity.cs b/src/core/Elsa.Abstractions/Services/CompositeActivity.cs
index 383f3e459..5043f305e 100644
--- a/src/core/Elsa.Abstractions/Services/CompositeActivity.cs
+++ b/src/core/Elsa.Abstractions/Services/CompositeActivity.cs
@@ -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();