feat: async chain end to end

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();
 }

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>()

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>()

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>()

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>()

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();
 }