diff --git a/backend/internal/service/scheduler_snapshot_service.go b/backend/internal/service/scheduler_snapshot_service.go
index 5ead45bc..62b6993d 100644
--- a/backend/internal/service/scheduler_snapshot_service.go
+++ b/backend/internal/service/scheduler_snapshot_service.go
@@ -264,11 +264,11 @@ func (s *SchedulerSnapshotService) pollOutbox() {
 	}
 
 	lastID := events[len(events)-1].ID
-	wmCtx, wmCancel := context.WithTimeout(context.Background(), 5*time.Second)
-	defer wmCancel()
 	var wmErr error
 	for i := range 3 {
+		wmCtx, wmCancel := context.WithTimeout(context.Background(), 5*time.Second)
 		wmErr = s.cache.SetOutboxWatermark(wmCtx, lastID)
+		wmCancel()
 		if wmErr == nil {
 			break
 		}