Skip to content

Commit eeccbf8

Browse files
committed
added recovery for cron
1 parent 0841368 commit eeccbf8

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

pkg/git/Watcher.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ import (
2323
"github.com/caarlos0/env"
2424
"github.com/devtron-labs/common-lib/constants"
2525
pubsub "github.com/devtron-labs/common-lib/pubsub-lib"
26+
"github.com/devtron-labs/common-lib/pubsub-lib/metrics"
2627
"github.com/devtron-labs/common-lib/pubsub-lib/model"
2728
"github.com/devtron-labs/git-sensor/internals"
2829
"github.com/devtron-labs/git-sensor/internals/middleware"
@@ -49,6 +50,8 @@ type GitWatcherImpl struct {
4950
gitManager GitManager
5051
}
5152

53+
const PANIC = "panic"
54+
5255
type GitWatcher interface {
5356
PollAndUpdateGitMaterial(material *sql.GitMaterial) (*sql.GitMaterial, error)
5457
}
@@ -371,6 +374,9 @@ func (impl *CronLoggerImpl) Info(msg string, keysAndValues ...interface{}) {
371374
}
372375

373376
func (impl *CronLoggerImpl) Error(err error, msg string, keysAndValues ...interface{}) {
377+
if msg == PANIC {
378+
metrics.IncPanicRecoveryCount("cron", "", "", "")
379+
}
374380
keysAndValues = append([]interface{}{"err", err}, keysAndValues...)
375381
impl.logger.Errorw(msg, keysAndValues...)
376382
}

0 commit comments

Comments
 (0)