cron report ignored pipeline cron

Author: chengjoey

apistructs/pipeline_report.go

@@ -24,6 +24,10 @@ import (
 const (
 	PipelineReportEventMetaKey = "event"
 	PipelineReportLoopMetaKey  = "task-loop"
+
+	// PipelineReportSystemPrefixMetaKey pipeline system log report key
+	PipelineReportSystemPrefixMetaKey = "pipeline-system-"
+	PipelineReportSystemIgnoreCronKey = PipelineReportSystemPrefixMetaKey + "ignored-cron"
 )
 
 // PipelineReportSet 流水线报告集，一条流水线可能会有多个报告，称为报告集

modules/pipeline/services/pipelinesvc/cron.go

@@ -58,8 +58,12 @@ func (s *PipelineSvc) RunCronPipelineFunc(id uint64) {
 
 	// 如果当前触发时间小于定时开始时间，return
 	if s.isCronShouldBeIgnored(pc) {
-		logrus.Warnf("crond: pipelineCronID: %d, triggered but ignored, triggerTime: %s, cronStartFrom: %s",
+		reason := fmt.Sprintf("crond: pipelineCronID: %d, triggered but ignored, triggerTime: %s, cronStartFrom: %s",
 			pc.ID, cronTriggerTime, *pc.Extra.CronStartFrom)
+		logrus.Warnf(reason)
+		if err := s.reportIgnoredCron(pc, reason); err != nil {
+			logrus.Errorf("crond: failed to report ignored cron, pipelineCronID: %d, err: %v", pc.ID, err)
+		}
 		return
 	}
 
@@ -226,3 +230,14 @@ func (s *PipelineSvc) DoCrondAbout(ctx context.Context) {
 	// 定时补偿
 	go s.ContinueCompensate(ctx)
 }
+
+func (s *PipelineSvc) reportIgnoredCron(pc spec.PipelineCron, reason string) error {
+	meta := map[string]interface{}{
+		fmt.Sprintf("%s-%d", apistructs.PipelineReportSystemIgnoreCronKey, pc.ID): pc,
+		"reason": reason,
+	}
+	return s.dbClient.CreatePipelineReport(&spec.PipelineReport{
+		Type: apistructs.PipelineReportSystemIgnoreCronKey,
+		Meta: meta,
+	})
+}