diff --git a/NEW/src/JdeScoping.DataSync/DevEtl/DevEtlRegistry.cs b/NEW/src/JdeScoping.DataSync/DevEtl/DevEtlRegistry.cs
index c8bff33..e681043 100644
--- a/NEW/src/JdeScoping.DataSync/DevEtl/DevEtlRegistry.cs
+++ b/NEW/src/JdeScoping.DataSync/DevEtl/DevEtlRegistry.cs
@@ -70,9 +70,7 @@ public class DevEtlRegistry
 
         foreach (var tableName in GetAvailableTables())
         {
-            if (cancellationToken.IsCancellationRequested)
-                break;
-
+            cancellationToken.ThrowIfCancellationRequested();
             var result = await RunAsync(tableName, cancellationToken);
             results.Add(result);
         }