diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs
index 466dc67..e3201e1 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.CreateChatRoom.Junctions;
@@ -11,7 +10,6 @@ public class CreateChatRoomTrain
     : ServiceTrain<CreateChatRoomInput, CreateChatRoomOutput>,
         ICreateChatRoomTrain
 {
-    protected override async Task<Either<Exception, CreateChatRoomOutput>> RunInternal(
-        CreateChatRoomInput input
-    ) => Activate(input).Chain<ValidateInputJunction>().Chain<PersistRoomJunction>().Resolve();
+    protected override CreateChatRoomOutput Junctions() =>
+        Chain<ValidateInputJunction>().Chain<PersistRoomJunction>();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs
index 0acf8a8..d2887c2 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.GetChatHistory.Junctions;
@@ -10,7 +9,5 @@ public class GetChatHistoryTrain
     : ServiceTrain<GetChatHistoryInput, GetChatHistoryOutput>,
         IGetChatHistoryTrain
 {
-    protected override async Task<Either<Exception, GetChatHistoryOutput>> RunInternal(
-        GetChatHistoryInput input
-    ) => Activate(input).Chain<FetchMessagesJunction>().Resolve();
+    protected override GetChatHistoryOutput Junctions() => Chain<FetchMessagesJunction>();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs
index 8755570..6fb7ab9 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.GetChatRooms.Junctions;
@@ -10,7 +9,5 @@ public class GetChatRoomsTrain
     : ServiceTrain<GetChatRoomsInput, GetChatRoomsOutput>,
         IGetChatRoomsTrain
 {
-    protected override async Task<Either<Exception, GetChatRoomsOutput>> RunInternal(
-        GetChatRoomsInput input
-    ) => Activate(input).Chain<FetchRoomsJunction>().Resolve();
+    protected override GetChatRoomsOutput Junctions() => Chain<FetchRoomsJunction>();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs
index 73b2c33..3de6b91 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.JoinChatRoom.Junctions;
@@ -11,7 +10,6 @@ public class JoinChatRoomTrain
     : ServiceTrain<JoinChatRoomInput, JoinChatRoomOutput>,
         IJoinChatRoomTrain
 {
-    protected override async Task<Either<Exception, JoinChatRoomOutput>> RunInternal(
-        JoinChatRoomInput input
-    ) => Activate(input).Chain<ValidateJoinJunction>().Chain<AddParticipantJunction>().Resolve();
+    protected override JoinChatRoomOutput Junctions() =>
+        Chain<ValidateJoinJunction>().Chain<AddParticipantJunction>();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs
index 65be8c1..762c267 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs
@@ -8,6 +8,5 @@ namespace Trax.Samples.ChatService.Trains.MarkChatAsRead;
 [TraxMutation(Description = "Marks a chat room as read for a user")]
 public class MarkChatAsReadTrain : ServiceTrain<MarkChatAsReadInput, Unit>, IMarkChatAsReadTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(MarkChatAsReadInput input) =>
-        Activate(input).Chain<UpdateLastReadJunction>().Resolve();
+    protected override Unit Junctions() => Chain<UpdateLastReadJunction>();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs
index bd97b65..460d9c7 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.SendMessage.Junctions;
@@ -9,7 +8,6 @@ namespace Trax.Samples.ChatService.Trains.SendMessage;
 [TraxBroadcast]
 public class SendMessageTrain : ServiceTrain<SendMessageInput, SendMessageOutput>, ISendMessageTrain
 {
-    protected override async Task<Either<Exception, SendMessageOutput>> RunInternal(
-        SendMessageInput input
-    ) => Activate(input).Chain<ValidateSenderJunction>().Chain<PersistMessageJunction>().Resolve();
+    protected override SendMessageOutput Junctions() =>
+        Chain<ValidateSenderJunction>().Chain<PersistMessageJunction>();
 }
diff --git a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/DataProcessingTrain.cs b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/DataProcessingTrain.cs
index 59f266d..0615887 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/DataProcessingTrain.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/DataProcessingTrain.cs
@@ -12,7 +12,5 @@ public class DataProcessingTrain
     : ServiceTrain<DataProcessingPipelineInput, Unit>,
         IDataProcessingTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        DataProcessingPipelineInput input
-    ) => Activate(input).Chain<ExecuteDataProcessingJunction>().Resolve();
+    protected override Unit Junctions() => Chain<ExecuteDataProcessingJunction>();
 }
diff --git a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/DataScienceTrain.cs b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/DataScienceTrain.cs
index c7269aa..ea2fcbf 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/DataScienceTrain.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/DataScienceTrain.cs
@@ -10,7 +10,5 @@ namespace Trax.Samples.Flowthru.Spaceflights.Trains.DataScience;
 /// </summary>
 public class DataScienceTrain : ServiceTrain<DataSciencePipelineInput, Unit>, IDataScienceTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        DataSciencePipelineInput input
-    ) => Activate(input).Chain<ExecuteDataScienceJunction>().Resolve();
+    protected override Unit Junctions() => Chain<ExecuteDataScienceJunction>();
 }
diff --git a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/ReportingTrain.cs b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/ReportingTrain.cs
index 2281338..5ecd7be 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/ReportingTrain.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/ReportingTrain.cs
@@ -10,7 +10,5 @@ namespace Trax.Samples.Flowthru.Spaceflights.Trains.Reporting;
 /// </summary>
 public class ReportingTrain : ServiceTrain<ReportingPipelineInput, Unit>, IReportingTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        ReportingPipelineInput input
-    ) => Activate(input).Chain<ExecuteReportingJunction>().Resolve();
+    protected override Unit Junctions() => Chain<ExecuteReportingJunction>();
 }
diff --git a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/BatteryStorage/ManageBatteryStorage/ManageBatteryStorageTrain.cs b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/BatteryStorage/ManageBatteryStorage/ManageBatteryStorageTrain.cs
index 8043847..415f0da 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/BatteryStorage/ManageBatteryStorage/ManageBatteryStorageTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/BatteryStorage/ManageBatteryStorage/ManageBatteryStorageTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.BatteryStorage.ManageBatteryStorage.Junctions;
@@ -20,11 +19,6 @@ public class ManageBatteryStorageTrain
     : ServiceTrain<ManageBatteryStorageInput, ManageBatteryStorageOutput>,
         IManageBatteryStorageTrain
 {
-    protected override async Task<Either<Exception, ManageBatteryStorageOutput>> RunInternal(
-        ManageBatteryStorageInput input
-    ) =>
-        Activate(input)
-            .Chain<ReadBatteryStateJunction>()
-            .Chain<OptimizeChargeLevelJunction>()
-            .Resolve();
+    protected override ManageBatteryStorageOutput Junctions() =>
+        Chain<ReadBatteryStateJunction>().Chain<OptimizeChargeLevelJunction>();
 }
diff --git a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/ChargingSessions/ProcessChargingSession/ProcessChargingSessionTrain.cs b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/ChargingSessions/ProcessChargingSession/ProcessChargingSessionTrain.cs
index bfad5cb..75ce283 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/ChargingSessions/ProcessChargingSession/ProcessChargingSessionTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/ChargingSessions/ProcessChargingSession/ProcessChargingSessionTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.ChargingSessions.ProcessChargingSession.Junctions;
@@ -16,11 +15,6 @@ public class ProcessChargingSessionTrain
     : ServiceTrain<ProcessChargingSessionInput, ProcessChargingSessionOutput>,
         IProcessChargingSessionTrain
 {
-    protected override async Task<Either<Exception, ProcessChargingSessionOutput>> RunInternal(
-        ProcessChargingSessionInput input
-    ) =>
-        Activate(input)
-            .Chain<CollectSessionDataJunction>()
-            .Chain<CalculateBillingJunction>()
-            .Resolve();
+    protected override ProcessChargingSessionOutput Junctions() =>
+        Chain<CollectSessionDataJunction>().Chain<CalculateBillingJunction>();
 }
diff --git a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs
index 98e7922..c4730d4 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.GridTrading.TradeGridEnergy.Junctions;
@@ -20,7 +19,6 @@ public class TradeGridEnergyTrain
     : ServiceTrain<TradeGridEnergyInput, TradeGridEnergyOutput>,
         ITradeGridEnergyTrain
 {
-    protected override async Task<Either<Exception, TradeGridEnergyOutput>> RunInternal(
-        TradeGridEnergyInput input
-    ) => Activate(input).Chain<CalculateExcessJunction>().Chain<SubmitToUbossJunction>().Resolve();
+    protected override TradeGridEnergyOutput Junctions() =>
+        Chain<CalculateExcessJunction>().Chain<SubmitToUbossJunction>();
 }
diff --git a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs
index e8e6862..da4a0d5 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs
@@ -19,11 +19,6 @@ public class OptimizeMicrogridTrain
     : ServiceTrain<OptimizeMicrogridInput, Unit>,
         IOptimizeMicrogridTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        OptimizeMicrogridInput input
-    ) =>
-        Activate(input)
-            .Chain<GatherEnergyMetricsJunction>()
-            .Chain<ApplyDistributionJunction>()
-            .Resolve();
+    protected override Unit Junctions() =>
+        Chain<GatherEnergyMetricsJunction>().Chain<ApplyDistributionJunction>();
 }
diff --git a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/SolarProduction/MonitorSolarProduction/MonitorSolarProductionTrain.cs b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/SolarProduction/MonitorSolarProduction/MonitorSolarProductionTrain.cs
index 9926d60..3c3a830 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/SolarProduction/MonitorSolarProduction/MonitorSolarProductionTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/SolarProduction/MonitorSolarProduction/MonitorSolarProductionTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.SolarProduction.MonitorSolarProduction.Junctions;
@@ -15,11 +14,6 @@ public class MonitorSolarProductionTrain
     : ServiceTrain<MonitorSolarProductionInput, MonitorSolarProductionOutput>,
         IMonitorSolarProductionTrain
 {
-    protected override async Task<Either<Exception, MonitorSolarProductionOutput>> RunInternal(
-        MonitorSolarProductionInput input
-    ) =>
-        Activate(input)
-            .Chain<ReadSolarSensorsJunction>()
-            .Chain<CalculateOutputJunction>()
-            .Resolve();
+    protected override MonitorSolarProductionOutput Junctions() =>
+        Chain<ReadSolarSensorsJunction>().Chain<CalculateOutputJunction>();
 }
diff --git a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Sustainability/GenerateSustainabilityReport/GenerateSustainabilityReportTrain.cs b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Sustainability/GenerateSustainabilityReport/GenerateSustainabilityReportTrain.cs
index 2bb8bd8..4971b01 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Sustainability/GenerateSustainabilityReport/GenerateSustainabilityReportTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Sustainability/GenerateSustainabilityReport/GenerateSustainabilityReportTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.Sustainability.GenerateSustainabilityReport.Junctions;
@@ -19,8 +18,6 @@ public class GenerateSustainabilityReportTrain
     : ServiceTrain<GenerateSustainabilityReportInput, GenerateSustainabilityReportOutput>,
         IGenerateSustainabilityReportTrain
 {
-    protected override async Task<
-        Either<Exception, GenerateSustainabilityReportOutput>
-    > RunInternal(GenerateSustainabilityReportInput input) =>
-        Activate(input).Chain<AggregateMetricsJunction>().Chain<PublishReportJunction>().Resolve();
+    protected override GenerateSustainabilityReportOutput Junctions() =>
+        Chain<AggregateMetricsJunction>().Chain<PublishReportJunction>();
 }
diff --git a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/LookupModerationResult/LookupModerationResultTrain.cs b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/LookupModerationResult/LookupModerationResultTrain.cs
index a579c7e..2631c31 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/LookupModerationResult/LookupModerationResultTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/LookupModerationResult/LookupModerationResultTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.ContentReview.LookupModerationResult.Junctions;
@@ -15,7 +14,5 @@ public class LookupModerationResultTrain
     : ServiceTrain<LookupModerationResultInput, ModerationResult>,
         ILookupModerationResultTrain
 {
-    protected override async Task<Either<Exception, ModerationResult>> RunInternal(
-        LookupModerationResultInput input
-    ) => Activate(input).Chain<FetchModerationResultJunction>().Resolve();
+    protected override ModerationResult Junctions() => Chain<FetchModerationResultJunction>();
 }
diff --git a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/ReviewContent/ReviewContentTrain.cs b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/ReviewContent/ReviewContentTrain.cs
index 4f009bb..24cd01e 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/ReviewContent/ReviewContentTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/ReviewContent/ReviewContentTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.ContentReview.ReviewContent.Junctions;
@@ -23,12 +22,6 @@ public class ReviewContentTrain
     : ServiceTrain<ReviewContentInput, ReviewContentOutput>,
         IReviewContentTrain
 {
-    protected override async Task<Either<Exception, ReviewContentOutput>> RunInternal(
-        ReviewContentInput input
-    ) =>
-        Activate(input)
-            .Chain<ClassifyContentJunction>()
-            .Chain<ScoreContentJunction>()
-            .Chain<FlagContentJunction>()
-            .Resolve();
+    protected override ReviewContentOutput Junctions() =>
+        Chain<ClassifyContentJunction>().Chain<ScoreContentJunction>().Chain<FlagContentJunction>();
 }
diff --git a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Notices/SendViolationNotice/SendViolationNoticeTrain.cs b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Notices/SendViolationNotice/SendViolationNoticeTrain.cs
index 6c58e4e..bc58b2a 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Notices/SendViolationNotice/SendViolationNoticeTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Notices/SendViolationNotice/SendViolationNoticeTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.Notices.SendViolationNotice.Junctions;
@@ -22,7 +21,6 @@ public class SendViolationNoticeTrain
     : ServiceTrain<SendViolationNoticeInput, SendViolationNoticeOutput>,
         ISendViolationNoticeTrain
 {
-    protected override async Task<Either<Exception, SendViolationNoticeOutput>> RunInternal(
-        SendViolationNoticeInput input
-    ) => Activate(input).Chain<ComposeNoticeJunction>().Chain<DeliverNoticeJunction>().Resolve();
+    protected override SendViolationNoticeOutput Junctions() =>
+        Chain<ComposeNoticeJunction>().Chain<DeliverNoticeJunction>();
 }
diff --git a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Reports/GenerateModerationReport/GenerateModerationReportTrain.cs b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Reports/GenerateModerationReport/GenerateModerationReportTrain.cs
index 8d8893c..ce2c11e 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Reports/GenerateModerationReport/GenerateModerationReportTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Reports/GenerateModerationReport/GenerateModerationReportTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.Reports.GenerateModerationReport.Junctions;
@@ -16,7 +15,6 @@ public class GenerateModerationReportTrain
     : ServiceTrain<GenerateModerationReportInput, GenerateModerationReportOutput>,
         IGenerateModerationReportTrain
 {
-    protected override async Task<Either<Exception, GenerateModerationReportOutput>> RunInternal(
-        GenerateModerationReportInput input
-    ) => Activate(input).Chain<AggregateMetricsJunction>().Chain<FormatReportJunction>().Resolve();
+    protected override GenerateModerationReportOutput Junctions() =>
+        Chain<AggregateMetricsJunction>().Chain<FormatReportJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/GenerateSeasonReport/GenerateSeasonReportTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/GenerateSeasonReport/GenerateSeasonReportTrain.cs
index 02a2c0d..d5fc079 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/GenerateSeasonReport/GenerateSeasonReportTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/GenerateSeasonReport/GenerateSeasonReportTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Leaderboard.GenerateSeasonReport.Junctions;
 
@@ -12,7 +11,6 @@ public class GenerateSeasonReportTrain
     : ServiceTrain<GenerateSeasonReportInput, SeasonReportOutput>,
         IGenerateSeasonReportTrain
 {
-    protected override async Task<Either<Exception, SeasonReportOutput>> RunInternal(
-        GenerateSeasonReportInput input
-    ) => Activate(input).Chain<CompileStatsJunction>().Chain<FormatReportJunction>().Resolve();
+    protected override SeasonReportOutput Junctions() =>
+        Chain<CompileStatsJunction>().Chain<FormatReportJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/RecalculateLeaderboard/RecalculateLeaderboardTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/RecalculateLeaderboard/RecalculateLeaderboardTrain.cs
index 73b8c64..443a35d 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/RecalculateLeaderboard/RecalculateLeaderboardTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/RecalculateLeaderboard/RecalculateLeaderboardTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Leaderboard.RecalculateLeaderboard.Junctions;
@@ -19,7 +18,6 @@ public class RecalculateLeaderboardTrain
     : ServiceTrain<RecalculateLeaderboardInput, RecalculateLeaderboardOutput>,
         IRecalculateLeaderboardTrain
 {
-    protected override async Task<Either<Exception, RecalculateLeaderboardOutput>> RunInternal(
-        RecalculateLeaderboardInput input
-    ) => Activate(input).Chain<AggregateScoresJunction>().Chain<RankPlayersJunction>().Resolve();
+    protected override RecalculateLeaderboardOutput Junctions() =>
+        Chain<AggregateScoresJunction>().Chain<RankPlayersJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Maintenance/CorruptedDataRepair/CorruptedDataRepairTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Maintenance/CorruptedDataRepair/CorruptedDataRepairTrain.cs
index 9c5f4c5..70d4f07 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Maintenance/CorruptedDataRepair/CorruptedDataRepairTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Maintenance/CorruptedDataRepair/CorruptedDataRepairTrain.cs
@@ -13,7 +13,5 @@ public class CorruptedDataRepairTrain
     : ServiceTrain<CorruptedDataRepairInput, Unit>,
         ICorruptedDataRepairTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        CorruptedDataRepairInput input
-    ) => Activate(input).Chain<AttemptRepairJunction>().Resolve();
+    protected override Unit Junctions() => Chain<AttemptRepairJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/DetectCheatPattern/DetectCheatPatternTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/DetectCheatPattern/DetectCheatPatternTrain.cs
index d9efb2c..5e3fcb0 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/DetectCheatPattern/DetectCheatPatternTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/DetectCheatPattern/DetectCheatPatternTrain.cs
@@ -13,7 +13,6 @@ public class DetectCheatPatternTrain
     : ServiceTrain<DetectCheatPatternInput, Unit>,
         IDetectCheatPatternTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        DetectCheatPatternInput input
-    ) => Activate(input).Chain<AnalyzePatternJunction>().Chain<FlagPlayerJunction>().Resolve();
+    protected override Unit Junctions() =>
+        Chain<AnalyzePatternJunction>().Chain<FlagPlayerJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/ProcessMatchResult/ProcessMatchResultTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/ProcessMatchResult/ProcessMatchResultTrain.cs
index 5c04607..feb31f6 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/ProcessMatchResult/ProcessMatchResultTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/ProcessMatchResult/ProcessMatchResultTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Matches.ProcessMatchResult.Junctions;
@@ -24,12 +23,8 @@ public class ProcessMatchResultTrain
     : ServiceTrain<ProcessMatchResultInput, ProcessMatchResultOutput>,
         IProcessMatchResultTrain
 {
-    protected override async Task<Either<Exception, ProcessMatchResultOutput>> RunInternal(
-        ProcessMatchResultInput input
-    ) =>
-        Activate(input)
-            .Chain<ValidateMatchJunction>()
+    protected override ProcessMatchResultOutput Junctions() =>
+        Chain<ValidateMatchJunction>()
             .Chain<UpdatePlayerStatsJunction>()
-            .Chain<CheckForAnomaliesJunction>()
-            .Resolve();
+            .Chain<CheckForAnomaliesJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/BanPlayer/BanPlayerTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/BanPlayer/BanPlayerTrain.cs
index 9274a44..cd619bf 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/BanPlayer/BanPlayerTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/BanPlayer/BanPlayerTrain.cs
@@ -22,8 +22,7 @@ public class BanPlayerTrain(ILogger<BanPlayerTrain> logger)
     : ServiceTrain<BanPlayerInput, Unit>,
         IBanPlayerTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(BanPlayerInput input) =>
-        Activate(input).Chain<ApplyBanJunction>().Resolve();
+    protected override Unit Junctions() => Chain<ApplyBanJunction>();
 
     protected override Task OnCompleted(Metadata metadata, CancellationToken ct)
     {
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/CleanupInactivePlayers/CleanupInactivePlayersTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/CleanupInactivePlayers/CleanupInactivePlayersTrain.cs
index 6bb0a02..d1811ff 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/CleanupInactivePlayers/CleanupInactivePlayersTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/CleanupInactivePlayers/CleanupInactivePlayersTrain.cs
@@ -12,8 +12,6 @@ public class CleanupInactivePlayersTrain
     : ServiceTrain<CleanupInactivePlayersInput, Unit>,
         ICleanupInactivePlayersTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        CleanupInactivePlayersInput input
-    ) =>
-        Activate(input).Chain<IdentifyInactiveJunction>().Chain<ArchivePlayersJunction>().Resolve();
+    protected override Unit Junctions() =>
+        Chain<IdentifyInactiveJunction>().Chain<ArchivePlayersJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/LookupPlayer/LookupPlayerTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/LookupPlayer/LookupPlayerTrain.cs
index 29f618c..512dcf7 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/LookupPlayer/LookupPlayerTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/LookupPlayer/LookupPlayerTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Players.LookupPlayer.Junctions;
@@ -13,7 +12,5 @@ namespace Trax.Samples.GameServer.Trains.Players.LookupPlayer;
 [TraxBroadcast]
 public class LookupPlayerTrain : ServiceTrain<LookupPlayerInput, PlayerProfile>, ILookupPlayerTrain
 {
-    protected override async Task<Either<Exception, PlayerProfile>> RunInternal(
-        LookupPlayerInput input
-    ) => Activate(input).Chain<FetchPlayerJunction>().Resolve();
+    protected override PlayerProfile Junctions() => Chain<FetchPlayerJunction>();
 }
diff --git a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Rewards/DistributeDailyRewards/DistributeDailyRewardsTrain.cs b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Rewards/DistributeDailyRewards/DistributeDailyRewardsTrain.cs
index abd2968..cbc8a7c 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Rewards/DistributeDailyRewards/DistributeDailyRewardsTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Rewards/DistributeDailyRewards/DistributeDailyRewardsTrain.cs
@@ -12,7 +12,6 @@ public class DistributeDailyRewardsTrain
     : ServiceTrain<DistributeDailyRewardsInput, Unit>,
         IDistributeDailyRewardsTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        DistributeDailyRewardsInput input
-    ) => Activate(input).Chain<CalculateRewardsJunction>().Chain<CreditPlayersJunction>().Resolve();
+    protected override Unit Junctions() =>
+        Chain<CalculateRewardsJunction>().Chain<CreditPlayersJunction>();
 }
diff --git a/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs b/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs
index b41c384..b0a0828 100644
--- a/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs
+++ b/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.TestRunner.Trains.DiscoverTestProjects.Junctions;
@@ -10,7 +9,5 @@ public class DiscoverTestProjectsTrain
     : ServiceTrain<DiscoverTestProjectsInput, DiscoverTestProjectsOutput>,
         IDiscoverTestProjectsTrain
 {
-    protected override async Task<Either<Exception, DiscoverTestProjectsOutput>> RunInternal(
-        DiscoverTestProjectsInput input
-    ) => Activate(input).Chain<ScanProjectsJunction>().Resolve();
+    protected override DiscoverTestProjectsOutput Junctions() => Chain<ScanProjectsJunction>();
 }
diff --git a/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs b/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs
index 95681af..ec8c250 100644
--- a/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs
+++ b/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.TestRunner.Trains.RunTests.Junctions;
@@ -9,7 +8,6 @@ namespace Trax.Samples.TestRunner.Trains.RunTests;
 [TraxBroadcast]
 public class RunTestsTrain : ServiceTrain<RunTestsInput, RunTestsOutput>, IRunTestsTrain
 {
-    protected override async Task<Either<Exception, RunTestsOutput>> RunInternal(
-        RunTestsInput input
-    ) => Activate(input).Chain<BuildProjectJunction>().Chain<ExecuteTestsJunction>().Resolve();
+    protected override RunTestsOutput Junctions() =>
+        Chain<BuildProjectJunction>().Chain<ExecuteTestsJunction>();
 }
diff --git a/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs b/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs
index cab5314..5ecf7e6 100644
--- a/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs
+++ b/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs
@@ -12,6 +12,5 @@ namespace Trax.Samples.Api.Trains.HelloWorld;
 [TraxMutation(GraphQLOperation.Run, Description = "Runs a hello world greeting")]
 public class HelloWorldTrain : ServiceTrain<HelloWorldInput, Unit>, IHelloWorldTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(HelloWorldInput input) =>
-        Activate(input).Chain<LogGreetingJunction>().Resolve();
+    protected override Unit Junctions() => Chain<LogGreetingJunction>();
 }
diff --git a/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs b/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs
index 53cbe32..87a4a5a 100644
--- a/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs
+++ b/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.Api.Trains.Lookup.Junctions;
@@ -12,6 +11,5 @@ namespace Trax.Samples.Api.Trains.Lookup;
 [TraxQuery(Description = "Looks up a record by ID")]
 public class LookupTrain : ServiceTrain<LookupInput, LookupOutput>, ILookupTrain
 {
-    protected override async Task<Either<Exception, LookupOutput>> RunInternal(LookupInput input) =>
-        Activate(input).Chain<FetchDataJunction>().Resolve();
+    protected override LookupOutput Junctions() => Chain<FetchDataJunction>();
 }
diff --git a/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs b/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs
index b3c3950..8366e0c 100644
--- a/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs
+++ b/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs
@@ -12,6 +12,5 @@ namespace Trax.Samples.Hub.Trains.HelloWorld;
 [TraxMutation(GraphQLOperation.Run, Description = "Runs a hello world greeting")]
 public class HelloWorldTrain : ServiceTrain<HelloWorldInput, Unit>, IHelloWorldTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(HelloWorldInput input) =>
-        Activate(input).Chain<LogGreetingJunction>().Resolve();
+    protected override Unit Junctions() => Chain<LogGreetingJunction>();
 }
diff --git a/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs b/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs
index 3eb3edb..a819f6c 100644
--- a/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs
+++ b/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs
@@ -1,4 +1,3 @@
-using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.Hub.Trains.Lookup.Junctions;
@@ -12,6 +11,5 @@ namespace Trax.Samples.Hub.Trains.Lookup;
 [TraxQuery(Description = "Looks up a record by ID")]
 public class LookupTrain : ServiceTrain<LookupInput, LookupOutput>, ILookupTrain
 {
-    protected override async Task<Either<Exception, LookupOutput>> RunInternal(LookupInput input) =>
-        Activate(input).Chain<FetchDataJunction>().Resolve();
+    protected override LookupOutput Junctions() => Chain<FetchDataJunction>();
 }
diff --git a/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs b/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs
index dc15e16..1651061 100644
--- a/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs
+++ b/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs
@@ -9,6 +9,5 @@ namespace Trax.Samples.Scheduler.Trains.HelloWorld;
 /// </summary>
 public class HelloWorldTrain : ServiceTrain<HelloWorldInput, Unit>, IHelloWorldTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(HelloWorldInput input) =>
-        Activate(input).Chain<LogGreetingJunction>().Resolve();
+    protected override Unit Junctions() => Chain<LogGreetingJunction>();
 }