chore(anchor): remove not started alerts

3box · Jan 2, 2023 · 4e7d672 · 4e7d672
1 parent 2c24d84
commit 4e7d672
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 54 deletions.
diff --git a/cd/manager/env/.env.prod b/cd/manager/env/.env.prod
@@ -1,3 +1,2 @@
 SMOKE_TEST_INTERVAL=6h
-CAS_MAX_ANCHOR_INTERVAL=6h
 ENV=prod
diff --git a/cd/manager/env/.env.qa b/cd/manager/env/.env.qa
@@ -1,4 +1,3 @@
 SMOKE_TEST_INTERVAL=6h
 E2E_TEST_INTERVAL=8h
-CAS_MAX_ANCHOR_INTERVAL=6h
 ENV=qa
diff --git a/cd/manager/env/.env.tnet b/cd/manager/env/.env.tnet
@@ -1,3 +1,2 @@
 SMOKE_TEST_INTERVAL=6h
-CAS_MAX_ANCHOR_INTERVAL=6h
 ENV=tnet
diff --git a/cd/manager/jobmanager/jobManager.go b/cd/manager/jobmanager/jobManager.go
@@ -13,7 +13,6 @@ import (
 
 	"github.com/3box/pipeline-tools/cd/manager"
 	"github.com/3box/pipeline-tools/cd/manager/jobs"
-	"github.com/3box/pipeline-tools/cd/manager/notifs"
 )
 
 var _ manager.Manager = &JobManager{}
@@ -140,9 +139,6 @@ func (m *JobManager) processJobs() {
 	if err := m.scheduleTests(); err != nil {
 		log.Printf("processJobs: error scheduling tests: %v", err)
 	}
-	if err := m.checkAnchorInterval(); err != nil {
-		log.Printf("processJobs: error checking anchor job interval: %v", err)
-	}
 	// Don't start any new jobs if the job manager is paused. Existing jobs will continue to be advanced.
 	if !m.paused {
 		// Always check if we have anchor jobs, even if none were dequeued. This is because we might have a minimum
@@ -231,20 +227,6 @@ func (m *JobManager) scheduleTests() error {
 	return nil
 }
 
-func (m *JobManager) checkAnchorInterval() error {
-	// Check time since the last anchor job was completed, if there isn't an anchor job already running.
-	activeAnchors := m.cache.JobsByMatcher(func(js manager.JobState) bool {
-		return manager.IsActiveJob(js) && (js.Type == manager.JobType_Anchor)
-	})
-	if len(activeAnchors) == 0 {
-		return m.checkJobInterval(manager.JobType_Anchor, manager.JobStage_Completed, "CAS_MAX_ANCHOR_INTERVAL", func(ts time.Time) error {
-			notifs.NewAnchorIntervalNotif(m.notifs).SendAlert(ts)
-			return nil
-		})
-	}
-	return nil
-}
-
 func (m *JobManager) checkJobInterval(jobType manager.JobType, jobStage manager.JobStage, intervalEnv string, processFn func(time.Time) error) error {
 	if interval, found := os.LookupEnv(intervalEnv); found {
 		if parsedInterval, err := time.ParseDuration(interval); err != nil {

diff --git a/cd/manager/notifs/anchorInterval.go b/cd/manager/notifs/anchorInterval.go