[-] fix self-destruct interval chains, fixes #631 (#637)

cybertec-postgresql · Jan 25, 2024 · d45e177 · d45e177
1 parent b75f72a
commit d45e177
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/internal/scheduler/interval_chain.go b/internal/scheduler/interval_chain.go
@@ -27,10 +27,6 @@ func (sch *Scheduler) isValid(ichain IntervalChain) bool {
 }
 
 func (sch *Scheduler) reschedule(ctx context.Context, ichain IntervalChain) {
-	if ichain.SelfDestruct {
-		sch.pgengine.DeleteChain(ctx, ichain.ChainID)
-		return
-	}
 	log.GetLogger(ctx).Debug("Sleeping before next execution of interval chain")
 	select {
 	case <-time.After(time.Duration(ichain.Interval) * time.Second):