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

---
 .../Trains/DeadLetterCleanup/DeadLetterCleanupTrain.cs       | 5 ++---
 .../Trains/JobDispatcher/JobDispatcherTrain.cs               | 2 +-
 src/Trax.Scheduler/Trains/JobRunner/JobRunnerTrain.cs        | 2 +-
 .../Trains/ManifestManager/InMemoryManifestManagerTrain.cs   | 2 +-
 .../Trains/ManifestManager/ManifestManagerTrain.cs           | 2 +-
 .../Trains/MetadataCleanup/MetadataCleanupTrain.cs           | 5 ++---
 6 files changed, 8 insertions(+), 10 deletions(-)

diff --git a/src/Trax.Scheduler/Trains/DeadLetterCleanup/DeadLetterCleanupTrain.cs b/src/Trax.Scheduler/Trains/DeadLetterCleanup/DeadLetterCleanupTrain.cs
index 124f278..9025f08 100644
--- a/src/Trax.Scheduler/Trains/DeadLetterCleanup/DeadLetterCleanupTrain.cs
+++ b/src/Trax.Scheduler/Trains/DeadLetterCleanup/DeadLetterCleanupTrain.cs
@@ -11,7 +11,6 @@ public class DeadLetterCleanupTrain
     : ServiceTrain<DeadLetterCleanupRequest, Unit>,
         IDeadLetterCleanupTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        DeadLetterCleanupRequest input
-    ) => Activate(input).Chain<DeleteResolvedDeadLettersJunction>().Resolve();
+    protected override Task<Either<Exception, Unit>> RunInternal(DeadLetterCleanupRequest input) =>
+        Activate(input).Chain<DeleteResolvedDeadLettersJunction>().Resolve();
 }
diff --git a/src/Trax.Scheduler/Trains/JobDispatcher/JobDispatcherTrain.cs b/src/Trax.Scheduler/Trains/JobDispatcher/JobDispatcherTrain.cs
index 8723c20..8edaadd 100644
--- a/src/Trax.Scheduler/Trains/JobDispatcher/JobDispatcherTrain.cs
+++ b/src/Trax.Scheduler/Trains/JobDispatcher/JobDispatcherTrain.cs
@@ -9,7 +9,7 @@ namespace Trax.Scheduler.Trains.JobDispatcher;
 /// </summary>
 public class JobDispatcherTrain : ServiceTrain<Unit, Unit>, IJobDispatcherTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(Unit input) =>
+    protected override Task<Either<Exception, Unit>> RunInternal(Unit input) =>
         Activate(input)
             .Chain<LoadQueuedJobsJunction>()
             .Chain<LoadDispatchCapacityJunction>()
diff --git a/src/Trax.Scheduler/Trains/JobRunner/JobRunnerTrain.cs b/src/Trax.Scheduler/Trains/JobRunner/JobRunnerTrain.cs
index 774a357..7d9171c 100644
--- a/src/Trax.Scheduler/Trains/JobRunner/JobRunnerTrain.cs
+++ b/src/Trax.Scheduler/Trains/JobRunner/JobRunnerTrain.cs
@@ -16,7 +16,7 @@ namespace Trax.Scheduler.Trains.JobRunner;
 /// </remarks>
 public class JobRunnerTrain : ServiceTrain<RunJobRequest, Unit>, IJobRunnerTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(RunJobRequest input) =>
+    protected override Task<Either<Exception, Unit>> RunInternal(RunJobRequest input) =>
         Activate(input)
             .Chain<LoadMetadataJunction>()
             .Chain<ValidateMetadataStateJunction>()
diff --git a/src/Trax.Scheduler/Trains/ManifestManager/InMemoryManifestManagerTrain.cs b/src/Trax.Scheduler/Trains/ManifestManager/InMemoryManifestManagerTrain.cs
index c5e23da..983d11c 100644
--- a/src/Trax.Scheduler/Trains/ManifestManager/InMemoryManifestManagerTrain.cs
+++ b/src/Trax.Scheduler/Trains/ManifestManager/InMemoryManifestManagerTrain.cs
@@ -20,7 +20,7 @@ namespace Trax.Scheduler.Trains.ManifestManager;
 /// </remarks>
 public class InMemoryManifestManagerTrain : ServiceTrain<Unit, Unit>, IManifestManagerTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(Unit input) =>
+    protected override Task<Either<Exception, Unit>> RunInternal(Unit input) =>
         Activate(input)
             .Chain<LoadManifestsJunction>()
             .Chain<ReapFailedJobsJunction>()
diff --git a/src/Trax.Scheduler/Trains/ManifestManager/ManifestManagerTrain.cs b/src/Trax.Scheduler/Trains/ManifestManager/ManifestManagerTrain.cs
index 7080135..4efe133 100644
--- a/src/Trax.Scheduler/Trains/ManifestManager/ManifestManagerTrain.cs
+++ b/src/Trax.Scheduler/Trains/ManifestManager/ManifestManagerTrain.cs
@@ -9,7 +9,7 @@ namespace Trax.Scheduler.Trains.ManifestManager;
 /// </summary>
 public class ManifestManagerTrain : ServiceTrain<Unit, Unit>, IManifestManagerTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(Unit input) =>
+    protected override Task<Either<Exception, Unit>> RunInternal(Unit input) =>
         Activate(input)
             .Chain<LoadManifestsJunction>()
             .Chain<CancelTimedOutJobsJunction>()
diff --git a/src/Trax.Scheduler/Trains/MetadataCleanup/MetadataCleanupTrain.cs b/src/Trax.Scheduler/Trains/MetadataCleanup/MetadataCleanupTrain.cs
index 7a8d13d..826decd 100644
--- a/src/Trax.Scheduler/Trains/MetadataCleanup/MetadataCleanupTrain.cs
+++ b/src/Trax.Scheduler/Trains/MetadataCleanup/MetadataCleanupTrain.cs
@@ -11,7 +11,6 @@ public class MetadataCleanupTrain
     : ServiceTrain<MetadataCleanupRequest, Unit>,
         IMetadataCleanupTrain
 {
-    protected override async Task<Either<Exception, Unit>> RunInternal(
-        MetadataCleanupRequest input
-    ) => Activate(input).Chain<DeleteExpiredMetadataJunction>().Resolve();
+    protected override Task<Either<Exception, Unit>> RunInternal(MetadataCleanupRequest input) =>
+        Activate(input).Chain<DeleteExpiredMetadataJunction>().Resolve();
 }