From 0c69248446c2874cf2e99a7a4106f82d656dfcd7 Mon Sep 17 00:00:00 2001
From: Theaux Masquelier <43664045+Theauxm@users.noreply.github.com>
Date: Mon, 4 May 2026 09:17:10 -0600
Subject: [PATCH] feat: async chain end to end (preserves
 Chain/Resolve/Extract/ShortCircuit/AddServices names)

---
 .../ApiAudit/Trax.Samples.ApiAudit/Trains/EchoTrain.cs    | 4 +++-
 .../Trains/CreateChatRoom/CreateChatRoomTrain.cs          | 5 +++--
 .../Trains/GetChatHistory/GetChatHistoryTrain.cs          | 4 +++-
 .../Trains/GetChatRooms/GetChatRoomsTrain.cs              | 4 +++-
 .../Trains/JoinChatRoom/JoinChatRoomTrain.cs              | 5 +++--
 .../Trains/MarkChatAsRead/MarkChatAsReadTrain.cs          | 3 ++-
 .../Trains/SendMessage/SendMessageTrain.cs                | 5 +++--
 .../Trains/DataProcessing/DataProcessingTrain.cs          | 3 ++-
 .../Trains/DataScience/DataScienceTrain.cs                | 3 ++-
 .../Trains/Reporting/ReportingTrain.cs                    | 3 ++-
 .../ManageBatteryStorage/ManageBatteryStorageTrain.cs     | 5 +++--
 .../ProcessChargingSession/ProcessChargingSessionTrain.cs | 5 +++--
 .../GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs   | 5 +++--
 .../Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs | 4 ++--
 .../MonitorSolarProduction/MonitorSolarProductionTrain.cs | 5 +++--
 .../GenerateSustainabilityReportTrain.cs                  | 5 +++--
 .../LookupModerationResult/LookupModerationResultTrain.cs | 4 +++-
 .../ContentReview/ReviewContent/ReviewContentTrain.cs     | 8 ++++++--
 .../SendViolationNotice/SendViolationNoticeTrain.cs       | 5 +++--
 .../GenerateModerationReportTrain.cs                      | 5 +++--
 .../Trax.Samples.JobHunt/Trains/AddJob/AddJobTrain.cs     | 6 ++++--
 .../Trains/CreateApplication/CreateApplicationTrain.cs    | 4 +++-
 .../Trains/FindContact/FindContactTrain.cs                | 4 +++-
 .../GenerateApplicationMaterialsTrain.cs                  | 6 ++++--
 .../Trains/GetArtifacts/GetArtifactsTrain.cs              | 4 +++-
 .../Trains/GetProfile/GetProfileTrain.cs                  | 4 +++-
 .../Trains/ListApplications/ListApplicationsTrain.cs      | 4 +++-
 .../Trax.Samples.JobHunt/Trains/ListJobs/ListJobsTrain.cs | 4 +++-
 .../ListWatchedCompanies/ListWatchedCompaniesTrain.cs     | 5 +++--
 .../MonitorAllActiveJobs/MonitorAllActiveJobsTrain.cs     | 4 +++-
 .../MonitorAllWatchedCompaniesTrain.cs                    | 5 +++--
 .../Trains/MonitorJob/MonitorJobTrain.cs                  | 6 ++++--
 .../Trains/UpdateProfile/UpdateProfileTrain.cs            | 5 +++--
 .../Trains/WatchCompany/WatchCompanyTrain.cs              | 4 +++-
 .../GenerateSeasonReport/GenerateSeasonReportTrain.cs     | 5 +++--
 .../RecalculateLeaderboard/RecalculateLeaderboardTrain.cs | 5 +++--
 .../CorruptedDataRepair/CorruptedDataRepairTrain.cs       | 3 ++-
 .../Matches/DetectCheatPattern/DetectCheatPatternTrain.cs | 4 ++--
 .../Matches/ProcessMatchResult/ProcessMatchResultTrain.cs | 6 ++++--
 .../Trains/Players/BanPlayer/BanPlayerTrain.cs            | 3 ++-
 .../CleanupInactivePlayers/CleanupInactivePlayersTrain.cs | 4 ++--
 .../Trains/Players/LookupPlayer/LookupPlayerTrain.cs      | 4 +++-
 .../DistributeDailyRewards/DistributeDailyRewardsTrain.cs | 4 ++--
 .../DiscoverTestProjects/DiscoverTestProjectsTrain.cs     | 4 +++-
 .../Trains/RunTests/RunTestsTrain.cs                      | 5 +++--
 .../Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs | 3 ++-
 .../content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs | 4 +++-
 .../Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs | 3 ++-
 .../content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs | 4 +++-
 .../Trains/HelloWorld/HelloWorldTrain.cs                  | 3 ++-
 50 files changed, 144 insertions(+), 75 deletions(-)

diff --git a/samples/ApiAudit/Trax.Samples.ApiAudit/Trains/EchoTrain.cs b/samples/ApiAudit/Trax.Samples.ApiAudit/Trains/EchoTrain.cs
index 10215ae..d36b999 100644
--- a/samples/ApiAudit/Trax.Samples.ApiAudit/Trains/EchoTrain.cs
+++ b/samples/ApiAudit/Trax.Samples.ApiAudit/Trains/EchoTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Core.Junction;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
@@ -13,7 +14,8 @@ public interface IEchoTrain : IServiceTrain<EchoInput, EchoOutput>;
 [TraxQuery]
 public class EchoTrain : ServiceTrain<EchoInput, EchoOutput>, IEchoTrain
 {
-    protected override EchoOutput Junctions() => Chain<EchoJunction>();
+    protected override Task<Either<Exception, EchoOutput>> Junctions() =>
+        Chain<EchoJunction>().Resolve();
 }
 
 public class EchoJunction : Junction<EchoInput, EchoOutput>
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs
index e3201e1..56efcd5 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/CreateChatRoom/CreateChatRoomTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.CreateChatRoom.Junctions;
@@ -10,6 +11,6 @@ public class CreateChatRoomTrain
     : ServiceTrain<CreateChatRoomInput, CreateChatRoomOutput>,
         ICreateChatRoomTrain
 {
-    protected override CreateChatRoomOutput Junctions() =>
-        Chain<ValidateInputJunction>().Chain<PersistRoomJunction>();
+    protected override Task<Either<Exception, CreateChatRoomOutput>> Junctions() =>
+        Chain<ValidateInputJunction>().Chain<PersistRoomJunction>().Resolve();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs
index d2887c2..7bd3b71 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatHistory/GetChatHistoryTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.GetChatHistory.Junctions;
@@ -9,5 +10,6 @@ public class GetChatHistoryTrain
     : ServiceTrain<GetChatHistoryInput, GetChatHistoryOutput>,
         IGetChatHistoryTrain
 {
-    protected override GetChatHistoryOutput Junctions() => Chain<FetchMessagesJunction>();
+    protected override Task<Either<Exception, GetChatHistoryOutput>> Junctions() =>
+        Chain<FetchMessagesJunction>().Resolve();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs
index 6fb7ab9..ec5b72b 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/GetChatRooms/GetChatRoomsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.GetChatRooms.Junctions;
@@ -9,5 +10,6 @@ public class GetChatRoomsTrain
     : ServiceTrain<GetChatRoomsInput, GetChatRoomsOutput>,
         IGetChatRoomsTrain
 {
-    protected override GetChatRoomsOutput Junctions() => Chain<FetchRoomsJunction>();
+    protected override Task<Either<Exception, GetChatRoomsOutput>> Junctions() =>
+        Chain<FetchRoomsJunction>().Resolve();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs
index 3de6b91..cd6dcc4 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/JoinChatRoom/JoinChatRoomTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.JoinChatRoom.Junctions;
@@ -10,6 +11,6 @@ public class JoinChatRoomTrain
     : ServiceTrain<JoinChatRoomInput, JoinChatRoomOutput>,
         IJoinChatRoomTrain
 {
-    protected override JoinChatRoomOutput Junctions() =>
-        Chain<ValidateJoinJunction>().Chain<AddParticipantJunction>();
+    protected override Task<Either<Exception, JoinChatRoomOutput>> Junctions() =>
+        Chain<ValidateJoinJunction>().Chain<AddParticipantJunction>().Resolve();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs
index 762c267..5c7b009 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/MarkChatAsRead/MarkChatAsReadTrain.cs
@@ -8,5 +8,6 @@ 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 Unit Junctions() => Chain<UpdateLastReadJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<UpdateLastReadJunction>().Resolve();
 }
diff --git a/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs b/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs
index 460d9c7..88085a5 100644
--- a/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs
+++ b/samples/ChatService/Trax.Samples.ChatService/Trains/SendMessage/SendMessageTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ChatService.Trains.SendMessage.Junctions;
@@ -8,6 +9,6 @@ namespace Trax.Samples.ChatService.Trains.SendMessage;
 [TraxBroadcast]
 public class SendMessageTrain : ServiceTrain<SendMessageInput, SendMessageOutput>, ISendMessageTrain
 {
-    protected override SendMessageOutput Junctions() =>
-        Chain<ValidateSenderJunction>().Chain<PersistMessageJunction>();
+    protected override Task<Either<Exception, SendMessageOutput>> Junctions() =>
+        Chain<ValidateSenderJunction>().Chain<PersistMessageJunction>().Resolve();
 }
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 0615887..5663a63 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/DataProcessingTrain.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/DataProcessingTrain.cs
@@ -12,5 +12,6 @@ public class DataProcessingTrain
     : ServiceTrain<DataProcessingPipelineInput, Unit>,
         IDataProcessingTrain
 {
-    protected override Unit Junctions() => Chain<ExecuteDataProcessingJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<ExecuteDataProcessingJunction>().Resolve();
 }
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 ea2fcbf..7d768a0 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/DataScienceTrain.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/DataScienceTrain.cs
@@ -10,5 +10,6 @@ namespace Trax.Samples.Flowthru.Spaceflights.Trains.DataScience;
 /// </summary>
 public class DataScienceTrain : ServiceTrain<DataSciencePipelineInput, Unit>, IDataScienceTrain
 {
-    protected override Unit Junctions() => Chain<ExecuteDataScienceJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<ExecuteDataScienceJunction>().Resolve();
 }
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 5ecd7be..86d1367 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/ReportingTrain.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/ReportingTrain.cs
@@ -10,5 +10,6 @@ namespace Trax.Samples.Flowthru.Spaceflights.Trains.Reporting;
 /// </summary>
 public class ReportingTrain : ServiceTrain<ReportingPipelineInput, Unit>, IReportingTrain
 {
-    protected override Unit Junctions() => Chain<ExecuteReportingJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<ExecuteReportingJunction>().Resolve();
 }
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 415f0da..c7d0b3e 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/BatteryStorage/ManageBatteryStorage/ManageBatteryStorageTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/BatteryStorage/ManageBatteryStorage/ManageBatteryStorageTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.BatteryStorage.ManageBatteryStorage.Junctions;
@@ -19,6 +20,6 @@ public class ManageBatteryStorageTrain
     : ServiceTrain<ManageBatteryStorageInput, ManageBatteryStorageOutput>,
         IManageBatteryStorageTrain
 {
-    protected override ManageBatteryStorageOutput Junctions() =>
-        Chain<ReadBatteryStateJunction>().Chain<OptimizeChargeLevelJunction>();
+    protected override Task<Either<Exception, ManageBatteryStorageOutput>> Junctions() =>
+        Chain<ReadBatteryStateJunction>().Chain<OptimizeChargeLevelJunction>().Resolve();
 }
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 75ce283..55d8802 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/ChargingSessions/ProcessChargingSession/ProcessChargingSessionTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/ChargingSessions/ProcessChargingSession/ProcessChargingSessionTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.ChargingSessions.ProcessChargingSession.Junctions;
@@ -15,6 +16,6 @@ public class ProcessChargingSessionTrain
     : ServiceTrain<ProcessChargingSessionInput, ProcessChargingSessionOutput>,
         IProcessChargingSessionTrain
 {
-    protected override ProcessChargingSessionOutput Junctions() =>
-        Chain<CollectSessionDataJunction>().Chain<CalculateBillingJunction>();
+    protected override Task<Either<Exception, ProcessChargingSessionOutput>> Junctions() =>
+        Chain<CollectSessionDataJunction>().Chain<CalculateBillingJunction>().Resolve();
 }
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 c4730d4..73be565 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/GridTrading/TradeGridEnergy/TradeGridEnergyTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.GridTrading.TradeGridEnergy.Junctions;
@@ -19,6 +20,6 @@ public class TradeGridEnergyTrain
     : ServiceTrain<TradeGridEnergyInput, TradeGridEnergyOutput>,
         ITradeGridEnergyTrain
 {
-    protected override TradeGridEnergyOutput Junctions() =>
-        Chain<CalculateExcessJunction>().Chain<SubmitToUbossJunction>();
+    protected override Task<Either<Exception, TradeGridEnergyOutput>> Junctions() =>
+        Chain<CalculateExcessJunction>().Chain<SubmitToUbossJunction>().Resolve();
 }
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 da4a0d5..5c97c33 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Microgrid/OptimizeMicrogrid/OptimizeMicrogridTrain.cs
@@ -19,6 +19,6 @@ public class OptimizeMicrogridTrain
     : ServiceTrain<OptimizeMicrogridInput, Unit>,
         IOptimizeMicrogridTrain
 {
-    protected override Unit Junctions() =>
-        Chain<GatherEnergyMetricsJunction>().Chain<ApplyDistributionJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<GatherEnergyMetricsJunction>().Chain<ApplyDistributionJunction>().Resolve();
 }
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 3c3a830..bb94f21 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/SolarProduction/MonitorSolarProduction/MonitorSolarProductionTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/SolarProduction/MonitorSolarProduction/MonitorSolarProductionTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.SolarProduction.MonitorSolarProduction.Junctions;
@@ -14,6 +15,6 @@ public class MonitorSolarProductionTrain
     : ServiceTrain<MonitorSolarProductionInput, MonitorSolarProductionOutput>,
         IMonitorSolarProductionTrain
 {
-    protected override MonitorSolarProductionOutput Junctions() =>
-        Chain<ReadSolarSensorsJunction>().Chain<CalculateOutputJunction>();
+    protected override Task<Either<Exception, MonitorSolarProductionOutput>> Junctions() =>
+        Chain<ReadSolarSensorsJunction>().Chain<CalculateOutputJunction>().Resolve();
 }
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 4971b01..09b1b00 100644
--- a/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Sustainability/GenerateSustainabilityReport/GenerateSustainabilityReportTrain.cs
+++ b/samples/DistributedWorkers/Trax.Samples.EnergyHub/Trains/Sustainability/GenerateSustainabilityReport/GenerateSustainabilityReportTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.EnergyHub.Trains.Sustainability.GenerateSustainabilityReport.Junctions;
@@ -18,6 +19,6 @@ public class GenerateSustainabilityReportTrain
     : ServiceTrain<GenerateSustainabilityReportInput, GenerateSustainabilityReportOutput>,
         IGenerateSustainabilityReportTrain
 {
-    protected override GenerateSustainabilityReportOutput Junctions() =>
-        Chain<AggregateMetricsJunction>().Chain<PublishReportJunction>();
+    protected override Task<Either<Exception, GenerateSustainabilityReportOutput>> Junctions() =>
+        Chain<AggregateMetricsJunction>().Chain<PublishReportJunction>().Resolve();
 }
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 2631c31..95e11a5 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/LookupModerationResult/LookupModerationResultTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/LookupModerationResult/LookupModerationResultTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.ContentReview.LookupModerationResult.Junctions;
@@ -14,5 +15,6 @@ public class LookupModerationResultTrain
     : ServiceTrain<LookupModerationResultInput, ModerationResult>,
         ILookupModerationResultTrain
 {
-    protected override ModerationResult Junctions() => Chain<FetchModerationResultJunction>();
+    protected override Task<Either<Exception, ModerationResult>> Junctions() =>
+        Chain<FetchModerationResultJunction>().Resolve();
 }
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 24cd01e..3de735b 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/ReviewContent/ReviewContentTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/ContentReview/ReviewContent/ReviewContentTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.ContentReview.ReviewContent.Junctions;
@@ -22,6 +23,9 @@ public class ReviewContentTrain
     : ServiceTrain<ReviewContentInput, ReviewContentOutput>,
         IReviewContentTrain
 {
-    protected override ReviewContentOutput Junctions() =>
-        Chain<ClassifyContentJunction>().Chain<ScoreContentJunction>().Chain<FlagContentJunction>();
+    protected override Task<Either<Exception, ReviewContentOutput>> Junctions() =>
+        Chain<ClassifyContentJunction>()
+            .Chain<ScoreContentJunction>()
+            .Chain<FlagContentJunction>()
+            .Resolve();
 }
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 bc58b2a..40aad37 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Notices/SendViolationNotice/SendViolationNoticeTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Notices/SendViolationNotice/SendViolationNoticeTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.Notices.SendViolationNotice.Junctions;
@@ -21,6 +22,6 @@ public class SendViolationNoticeTrain
     : ServiceTrain<SendViolationNoticeInput, SendViolationNoticeOutput>,
         ISendViolationNoticeTrain
 {
-    protected override SendViolationNoticeOutput Junctions() =>
-        Chain<ComposeNoticeJunction>().Chain<DeliverNoticeJunction>();
+    protected override Task<Either<Exception, SendViolationNoticeOutput>> Junctions() =>
+        Chain<ComposeNoticeJunction>().Chain<DeliverNoticeJunction>().Resolve();
 }
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 ce2c11e..227c6cd 100644
--- a/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Reports/GenerateModerationReport/GenerateModerationReportTrain.cs
+++ b/samples/EphemeralWorkers/Trax.Samples.ContentShield/Trains/Reports/GenerateModerationReport/GenerateModerationReportTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.ContentShield.Trains.Reports.GenerateModerationReport.Junctions;
@@ -15,6 +16,6 @@ public class GenerateModerationReportTrain
     : ServiceTrain<GenerateModerationReportInput, GenerateModerationReportOutput>,
         IGenerateModerationReportTrain
 {
-    protected override GenerateModerationReportOutput Junctions() =>
-        Chain<AggregateMetricsJunction>().Chain<FormatReportJunction>();
+    protected override Task<Either<Exception, GenerateModerationReportOutput>> Junctions() =>
+        Chain<AggregateMetricsJunction>().Chain<FormatReportJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/AddJob/AddJobTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/AddJob/AddJobTrain.cs
index 1664489..6c12f50 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/AddJob/AddJobTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/AddJob/AddJobTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.AddJob.Junctions;
@@ -8,8 +9,9 @@ namespace Trax.Samples.JobHunt.Trains.AddJob;
 [TraxBroadcast]
 public class AddJobTrain : ServiceTrain<AddJobInput, AddJobOutput>, IAddJobTrain
 {
-    protected override AddJobOutput Junctions() =>
+    protected override Task<Either<Exception, AddJobOutput>> Junctions() =>
         Chain<ValidateAddJobInputJunction>()
             .Chain<FetchJobPostingJunction>()
-            .Chain<PersistJobJunction>();
+            .Chain<PersistJobJunction>()
+            .Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/CreateApplication/CreateApplicationTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/CreateApplication/CreateApplicationTrain.cs
index c9d9df4..1db1e42 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/CreateApplication/CreateApplicationTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/CreateApplication/CreateApplicationTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.CreateApplication.Junctions;
@@ -9,5 +10,6 @@ public class CreateApplicationTrain
     : ServiceTrain<CreateApplicationInput, CreateApplicationOutput>,
         ICreateApplicationTrain
 {
-    protected override CreateApplicationOutput Junctions() => Chain<PersistApplicationJunction>();
+    protected override Task<Either<Exception, CreateApplicationOutput>> Junctions() =>
+        Chain<PersistApplicationJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/FindContact/FindContactTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/FindContact/FindContactTrain.cs
index 6ad23df..64e0a9b 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/FindContact/FindContactTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/FindContact/FindContactTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.FindContact.Junctions;
@@ -8,5 +9,6 @@ namespace Trax.Samples.JobHunt.Trains.FindContact;
 [TraxBroadcast]
 public class FindContactTrain : ServiceTrain<FindContactInput, FindContactOutput>, IFindContactTrain
 {
-    protected override FindContactOutput Junctions() => Chain<PersistContactJunction>();
+    protected override Task<Either<Exception, FindContactOutput>> Junctions() =>
+        Chain<PersistContactJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/GenerateApplicationMaterials/GenerateApplicationMaterialsTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/GenerateApplicationMaterials/GenerateApplicationMaterialsTrain.cs
index 3ef544f..9470095 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/GenerateApplicationMaterials/GenerateApplicationMaterialsTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/GenerateApplicationMaterials/GenerateApplicationMaterialsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.GenerateApplicationMaterials.Junctions;
@@ -10,9 +11,10 @@ public class GenerateApplicationMaterialsTrain
     : ServiceTrain<GenerateApplicationMaterialsInput, GenerateApplicationMaterialsOutput>,
         IGenerateApplicationMaterialsTrain
 {
-    protected override GenerateApplicationMaterialsOutput Junctions() =>
+    protected override Task<Either<Exception, GenerateApplicationMaterialsOutput>> Junctions() =>
         Chain<LoadJobAndProfileJunction>()
             .Chain<GenerateResumeJunction>()
             .Chain<GenerateCoverLetterJunction>()
-            .Chain<PersistArtifactsJunction>();
+            .Chain<PersistArtifactsJunction>()
+            .Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetArtifacts/GetArtifactsTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetArtifacts/GetArtifactsTrain.cs
index 867566a..7304504 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetArtifacts/GetArtifactsTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetArtifacts/GetArtifactsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.GetArtifacts.Junctions;
@@ -9,5 +10,6 @@ public class GetArtifactsTrain
     : ServiceTrain<GetArtifactsInput, GetArtifactsOutput>,
         IGetArtifactsTrain
 {
-    protected override GetArtifactsOutput Junctions() => Chain<LoadArtifactsJunction>();
+    protected override Task<Either<Exception, GetArtifactsOutput>> Junctions() =>
+        Chain<LoadArtifactsJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetProfile/GetProfileTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetProfile/GetProfileTrain.cs
index 7649c0f..79dcc65 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetProfile/GetProfileTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/GetProfile/GetProfileTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.GetProfile.Junctions;
@@ -7,5 +8,6 @@ namespace Trax.Samples.JobHunt.Trains.GetProfile;
 [TraxQuery(Description = "Returns the user's profile or a default empty profile")]
 public class GetProfileTrain : ServiceTrain<GetProfileInput, GetProfileOutput>, IGetProfileTrain
 {
-    protected override GetProfileOutput Junctions() => Chain<LoadProfileJunction>();
+    protected override Task<Either<Exception, GetProfileOutput>> Junctions() =>
+        Chain<LoadProfileJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListApplications/ListApplicationsTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListApplications/ListApplicationsTrain.cs
index fe20d64..11c880a 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListApplications/ListApplicationsTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListApplications/ListApplicationsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.ListApplications.Junctions;
@@ -9,5 +10,6 @@ public class ListApplicationsTrain
     : ServiceTrain<ListApplicationsInput, ListApplicationsOutput>,
         IListApplicationsTrain
 {
-    protected override ListApplicationsOutput Junctions() => Chain<LoadApplicationsJunction>();
+    protected override Task<Either<Exception, ListApplicationsOutput>> Junctions() =>
+        Chain<LoadApplicationsJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListJobs/ListJobsTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListJobs/ListJobsTrain.cs
index 3bf8d7d..2fde901 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListJobs/ListJobsTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListJobs/ListJobsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.ListJobs.Junctions;
@@ -7,5 +8,6 @@ namespace Trax.Samples.JobHunt.Trains.ListJobs;
 [TraxQuery(Description = "Lists jobs for a user, optionally filtered by status")]
 public class ListJobsTrain : ServiceTrain<ListJobsInput, ListJobsOutput>, IListJobsTrain
 {
-    protected override ListJobsOutput Junctions() => Chain<LoadJobsJunction>();
+    protected override Task<Either<Exception, ListJobsOutput>> Junctions() =>
+        Chain<LoadJobsJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListWatchedCompanies/ListWatchedCompaniesTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListWatchedCompanies/ListWatchedCompaniesTrain.cs
index 920f7bd..a2283bd 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListWatchedCompanies/ListWatchedCompaniesTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/ListWatchedCompanies/ListWatchedCompaniesTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.ListWatchedCompanies.Junctions;
@@ -9,6 +10,6 @@ public class ListWatchedCompaniesTrain
     : ServiceTrain<ListWatchedCompaniesInput, ListWatchedCompaniesOutput>,
         IListWatchedCompaniesTrain
 {
-    protected override ListWatchedCompaniesOutput Junctions() =>
-        Chain<LoadWatchedCompaniesJunction>();
+    protected override Task<Either<Exception, ListWatchedCompaniesOutput>> Junctions() =>
+        Chain<LoadWatchedCompaniesJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllActiveJobs/MonitorAllActiveJobsTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllActiveJobs/MonitorAllActiveJobsTrain.cs
index 10dacf6..88202c0 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllActiveJobs/MonitorAllActiveJobsTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllActiveJobs/MonitorAllActiveJobsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.MonitorAllActiveJobs.Junctions;
 
@@ -7,5 +8,6 @@ public class MonitorAllActiveJobsTrain
     : ServiceTrain<MonitorAllActiveJobsInput, MonitorAllActiveJobsOutput>,
         IMonitorAllActiveJobsTrain
 {
-    protected override MonitorAllActiveJobsOutput Junctions() => Chain<FanOutMonitorJunction>();
+    protected override Task<Either<Exception, MonitorAllActiveJobsOutput>> Junctions() =>
+        Chain<FanOutMonitorJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllWatchedCompanies/MonitorAllWatchedCompaniesTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllWatchedCompanies/MonitorAllWatchedCompaniesTrain.cs
index 9e4754e..12f8342 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllWatchedCompanies/MonitorAllWatchedCompaniesTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorAllWatchedCompanies/MonitorAllWatchedCompaniesTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.MonitorAllWatchedCompanies.Junctions;
 
@@ -7,6 +8,6 @@ public class MonitorAllWatchedCompaniesTrain
     : ServiceTrain<MonitorAllWatchedCompaniesInput, MonitorAllWatchedCompaniesOutput>,
         IMonitorAllWatchedCompaniesTrain
 {
-    protected override MonitorAllWatchedCompaniesOutput Junctions() =>
-        Chain<FanOutCompanyMonitorJunction>();
+    protected override Task<Either<Exception, MonitorAllWatchedCompaniesOutput>> Junctions() =>
+        Chain<FanOutCompanyMonitorJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorJob/MonitorJobTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorJob/MonitorJobTrain.cs
index 07d4af1..7754c25 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorJob/MonitorJobTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/MonitorJob/MonitorJobTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.MonitorJob.Junctions;
 
@@ -5,8 +6,9 @@ namespace Trax.Samples.JobHunt.Trains.MonitorJob;
 
 public class MonitorJobTrain : ServiceTrain<MonitorJobInput, MonitorJobOutput>, IMonitorJobTrain
 {
-    protected override MonitorJobOutput Junctions() =>
+    protected override Task<Either<Exception, MonitorJobOutput>> Junctions() =>
         Chain<RefetchAndHashJunction>()
             .Chain<DiffAgainstLastSnapshotJunction>()
-            .Chain<PersistSnapshotAndUpdateJobJunction>();
+            .Chain<PersistSnapshotAndUpdateJobJunction>()
+            .Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/UpdateProfile/UpdateProfileTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/UpdateProfile/UpdateProfileTrain.cs
index 30a2c11..be32ab6 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/UpdateProfile/UpdateProfileTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/UpdateProfile/UpdateProfileTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.UpdateProfile.Junctions;
@@ -9,6 +10,6 @@ public class UpdateProfileTrain
     : ServiceTrain<UpdateProfileInput, UpdateProfileOutput>,
         IUpdateProfileTrain
 {
-    protected override UpdateProfileOutput Junctions() =>
-        Chain<ValidateProfileJsonJunction>().Chain<PersistProfileJunction>();
+    protected override Task<Either<Exception, UpdateProfileOutput>> Junctions() =>
+        Chain<ValidateProfileJsonJunction>().Chain<PersistProfileJunction>().Resolve();
 }
diff --git a/samples/JobHunt/Trax.Samples.JobHunt/Trains/WatchCompany/WatchCompanyTrain.cs b/samples/JobHunt/Trax.Samples.JobHunt/Trains/WatchCompany/WatchCompanyTrain.cs
index cb50af2..817873a 100644
--- a/samples/JobHunt/Trax.Samples.JobHunt/Trains/WatchCompany/WatchCompanyTrain.cs
+++ b/samples/JobHunt/Trax.Samples.JobHunt/Trains/WatchCompany/WatchCompanyTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.JobHunt.Trains.WatchCompany.Junctions;
@@ -9,5 +10,6 @@ public class WatchCompanyTrain
     : ServiceTrain<WatchCompanyInput, WatchCompanyOutput>,
         IWatchCompanyTrain
 {
-    protected override WatchCompanyOutput Junctions() => Chain<PersistWatchedCompanyJunction>();
+    protected override Task<Either<Exception, WatchCompanyOutput>> Junctions() =>
+        Chain<PersistWatchedCompanyJunction>().Resolve();
 }
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 d5fc079..25a06ba 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/GenerateSeasonReport/GenerateSeasonReportTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/GenerateSeasonReport/GenerateSeasonReportTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Leaderboard.GenerateSeasonReport.Junctions;
 
@@ -11,6 +12,6 @@ public class GenerateSeasonReportTrain
     : ServiceTrain<GenerateSeasonReportInput, SeasonReportOutput>,
         IGenerateSeasonReportTrain
 {
-    protected override SeasonReportOutput Junctions() =>
-        Chain<CompileStatsJunction>().Chain<FormatReportJunction>();
+    protected override Task<Either<Exception, SeasonReportOutput>> Junctions() =>
+        Chain<CompileStatsJunction>().Chain<FormatReportJunction>().Resolve();
 }
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 443a35d..b5cdd19 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/RecalculateLeaderboard/RecalculateLeaderboardTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Leaderboard/RecalculateLeaderboard/RecalculateLeaderboardTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Leaderboard.RecalculateLeaderboard.Junctions;
@@ -18,6 +19,6 @@ public class RecalculateLeaderboardTrain
     : ServiceTrain<RecalculateLeaderboardInput, RecalculateLeaderboardOutput>,
         IRecalculateLeaderboardTrain
 {
-    protected override RecalculateLeaderboardOutput Junctions() =>
-        Chain<AggregateScoresJunction>().Chain<RankPlayersJunction>();
+    protected override Task<Either<Exception, RecalculateLeaderboardOutput>> Junctions() =>
+        Chain<AggregateScoresJunction>().Chain<RankPlayersJunction>().Resolve();
 }
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 70d4f07..a2a5902 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Maintenance/CorruptedDataRepair/CorruptedDataRepairTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Maintenance/CorruptedDataRepair/CorruptedDataRepairTrain.cs
@@ -13,5 +13,6 @@ public class CorruptedDataRepairTrain
     : ServiceTrain<CorruptedDataRepairInput, Unit>,
         ICorruptedDataRepairTrain
 {
-    protected override Unit Junctions() => Chain<AttemptRepairJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<AttemptRepairJunction>().Resolve();
 }
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 5e3fcb0..31e3c8b 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/DetectCheatPattern/DetectCheatPatternTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/DetectCheatPattern/DetectCheatPatternTrain.cs
@@ -13,6 +13,6 @@ public class DetectCheatPatternTrain
     : ServiceTrain<DetectCheatPatternInput, Unit>,
         IDetectCheatPatternTrain
 {
-    protected override Unit Junctions() =>
-        Chain<AnalyzePatternJunction>().Chain<FlagPlayerJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<AnalyzePatternJunction>().Chain<FlagPlayerJunction>().Resolve();
 }
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 feb31f6..c6d62a7 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/ProcessMatchResult/ProcessMatchResultTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Matches/ProcessMatchResult/ProcessMatchResultTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Matches.ProcessMatchResult.Junctions;
@@ -23,8 +24,9 @@ public class ProcessMatchResultTrain
     : ServiceTrain<ProcessMatchResultInput, ProcessMatchResultOutput>,
         IProcessMatchResultTrain
 {
-    protected override ProcessMatchResultOutput Junctions() =>
+    protected override Task<Either<Exception, ProcessMatchResultOutput>> Junctions() =>
         Chain<ValidateMatchJunction>()
             .Chain<UpdatePlayerStatsJunction>()
-            .Chain<CheckForAnomaliesJunction>();
+            .Chain<CheckForAnomaliesJunction>()
+            .Resolve();
 }
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 83a3644..17aa5f1 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/BanPlayer/BanPlayerTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/BanPlayer/BanPlayerTrain.cs
@@ -22,7 +22,8 @@ public class BanPlayerTrain(ILogger<BanPlayerTrain> logger)
     : ServiceTrain<BanPlayerInput, Unit>,
         IBanPlayerTrain
 {
-    protected override Unit Junctions() => Chain<ApplyBanJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<ApplyBanJunction>().Resolve();
 
     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 d1811ff..fb7de32 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/CleanupInactivePlayers/CleanupInactivePlayersTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/CleanupInactivePlayers/CleanupInactivePlayersTrain.cs
@@ -12,6 +12,6 @@ public class CleanupInactivePlayersTrain
     : ServiceTrain<CleanupInactivePlayersInput, Unit>,
         ICleanupInactivePlayersTrain
 {
-    protected override Unit Junctions() =>
-        Chain<IdentifyInactiveJunction>().Chain<ArchivePlayersJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<IdentifyInactiveJunction>().Chain<ArchivePlayersJunction>().Resolve();
 }
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 512dcf7..07aa26d 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/LookupPlayer/LookupPlayerTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Players/LookupPlayer/LookupPlayerTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.GameServer.Trains.Players.LookupPlayer.Junctions;
@@ -12,5 +13,6 @@ namespace Trax.Samples.GameServer.Trains.Players.LookupPlayer;
 [TraxBroadcast]
 public class LookupPlayerTrain : ServiceTrain<LookupPlayerInput, PlayerProfile>, ILookupPlayerTrain
 {
-    protected override PlayerProfile Junctions() => Chain<FetchPlayerJunction>();
+    protected override Task<Either<Exception, PlayerProfile>> Junctions() =>
+        Chain<FetchPlayerJunction>().Resolve();
 }
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 cbc8a7c..8949e2d 100644
--- a/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Rewards/DistributeDailyRewards/DistributeDailyRewardsTrain.cs
+++ b/samples/LocalWorkers/Trax.Samples.GameServer/Trains/Rewards/DistributeDailyRewards/DistributeDailyRewardsTrain.cs
@@ -12,6 +12,6 @@ public class DistributeDailyRewardsTrain
     : ServiceTrain<DistributeDailyRewardsInput, Unit>,
         IDistributeDailyRewardsTrain
 {
-    protected override Unit Junctions() =>
-        Chain<CalculateRewardsJunction>().Chain<CreditPlayersJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<CalculateRewardsJunction>().Chain<CreditPlayersJunction>().Resolve();
 }
diff --git a/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs b/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs
index b0a0828..2d50c71 100644
--- a/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs
+++ b/samples/TestRunner/Trax.Samples.TestRunner/Trains/DiscoverTestProjects/DiscoverTestProjectsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.TestRunner.Trains.DiscoverTestProjects.Junctions;
@@ -9,5 +10,6 @@ public class DiscoverTestProjectsTrain
     : ServiceTrain<DiscoverTestProjectsInput, DiscoverTestProjectsOutput>,
         IDiscoverTestProjectsTrain
 {
-    protected override DiscoverTestProjectsOutput Junctions() => Chain<ScanProjectsJunction>();
+    protected override Task<Either<Exception, DiscoverTestProjectsOutput>> Junctions() =>
+        Chain<ScanProjectsJunction>().Resolve();
 }
diff --git a/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs b/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs
index ec8c250..ad29bcb 100644
--- a/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs
+++ b/samples/TestRunner/Trax.Samples.TestRunner/Trains/RunTests/RunTestsTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.TestRunner.Trains.RunTests.Junctions;
@@ -8,6 +9,6 @@ namespace Trax.Samples.TestRunner.Trains.RunTests;
 [TraxBroadcast]
 public class RunTestsTrain : ServiceTrain<RunTestsInput, RunTestsOutput>, IRunTestsTrain
 {
-    protected override RunTestsOutput Junctions() =>
-        Chain<BuildProjectJunction>().Chain<ExecuteTestsJunction>();
+    protected override Task<Either<Exception, RunTestsOutput>> Junctions() =>
+        Chain<BuildProjectJunction>().Chain<ExecuteTestsJunction>().Resolve();
 }
diff --git a/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs b/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs
index 5ecf7e6..aa1d4b9 100644
--- a/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs
+++ b/templates/content/Trax.Samples.Api/Trains/HelloWorld/HelloWorldTrain.cs
@@ -12,5 +12,6 @@ namespace Trax.Samples.Api.Trains.HelloWorld;
 [TraxMutation(GraphQLOperation.Run, Description = "Runs a hello world greeting")]
 public class HelloWorldTrain : ServiceTrain<HelloWorldInput, Unit>, IHelloWorldTrain
 {
-    protected override Unit Junctions() => Chain<LogGreetingJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<LogGreetingJunction>().Resolve();
 }
diff --git a/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs b/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs
index 87a4a5a..255a47a 100644
--- a/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs
+++ b/templates/content/Trax.Samples.Api/Trains/Lookup/LookupTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.Api.Trains.Lookup.Junctions;
@@ -11,5 +12,6 @@ namespace Trax.Samples.Api.Trains.Lookup;
 [TraxQuery(Description = "Looks up a record by ID")]
 public class LookupTrain : ServiceTrain<LookupInput, LookupOutput>, ILookupTrain
 {
-    protected override LookupOutput Junctions() => Chain<FetchDataJunction>();
+    protected override Task<Either<Exception, LookupOutput>> Junctions() =>
+        Chain<FetchDataJunction>().Resolve();
 }
diff --git a/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs b/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs
index 8366e0c..c29c300 100644
--- a/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs
+++ b/templates/content/Trax.Samples.Hub/Trains/HelloWorld/HelloWorldTrain.cs
@@ -12,5 +12,6 @@ namespace Trax.Samples.Hub.Trains.HelloWorld;
 [TraxMutation(GraphQLOperation.Run, Description = "Runs a hello world greeting")]
 public class HelloWorldTrain : ServiceTrain<HelloWorldInput, Unit>, IHelloWorldTrain
 {
-    protected override Unit Junctions() => Chain<LogGreetingJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<LogGreetingJunction>().Resolve();
 }
diff --git a/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs b/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs
index a819f6c..4637ed9 100644
--- a/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs
+++ b/templates/content/Trax.Samples.Hub/Trains/Lookup/LookupTrain.cs
@@ -1,3 +1,4 @@
+using LanguageExt;
 using Trax.Effect.Attributes;
 using Trax.Effect.Services.ServiceTrain;
 using Trax.Samples.Hub.Trains.Lookup.Junctions;
@@ -11,5 +12,6 @@ namespace Trax.Samples.Hub.Trains.Lookup;
 [TraxQuery(Description = "Looks up a record by ID")]
 public class LookupTrain : ServiceTrain<LookupInput, LookupOutput>, ILookupTrain
 {
-    protected override LookupOutput Junctions() => Chain<FetchDataJunction>();
+    protected override Task<Either<Exception, LookupOutput>> Junctions() =>
+        Chain<FetchDataJunction>().Resolve();
 }
diff --git a/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs b/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs
index 1651061..f92d3be 100644
--- a/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs
+++ b/templates/content/Trax.Samples.Scheduler/Trains/HelloWorld/HelloWorldTrain.cs
@@ -9,5 +9,6 @@ namespace Trax.Samples.Scheduler.Trains.HelloWorld;
 /// </summary>
 public class HelloWorldTrain : ServiceTrain<HelloWorldInput, Unit>, IHelloWorldTrain
 {
-    protected override Unit Junctions() => Chain<LogGreetingJunction>();
+    protected override Task<Either<Exception, Unit>> Junctions() =>
+        Chain<LogGreetingJunction>().Resolve();
 }