diff --git a/trex_core/application/snapshot_scheduler.py b/trex_core/application/snapshot_scheduler.py
index ca50da9..287570a 100644
--- a/trex_core/application/snapshot_scheduler.py
+++ b/trex_core/application/snapshot_scheduler.py
@@ -384,7 +384,7 @@ class SnapshotScheduler:
                     state["consecutive_failures"],
                     backoff,
                 )
-            return
+            raise
         lifecycle = self._balance_health.record_success(worker)
         if lifecycle == "recovered":
             state = self._balance_health.status(worker, stale_after_sec=stale_after_sec)