diff --git a/flow/alerting/alerting.go b/flow/alerting/alerting.go index fe6c8a102d..ff29efb65d 100644 --- a/flow/alerting/alerting.go +++ b/flow/alerting/alerting.go @@ -243,6 +243,10 @@ func (a *Alerter) checkAndAddAlertToCatalog(ctx context.Context, alertConfigId i } return true } + + logger.LoggerFromCtx(ctx).Info( + fmt.Sprintf("Skipeed sending alerts: last alert was sent at %s, which was >=%s ago", + createdTimestamp.String(), dur.String())) return false } diff --git a/flow/alerting/email_alert_sender.go b/flow/alerting/email_alert_sender.go index 20d85a3c82..2a534318c0 100644 --- a/flow/alerting/email_alert_sender.go +++ b/flow/alerting/email_alert_sender.go @@ -3,6 +3,7 @@ package alerting import ( "context" "fmt" + "github.com/aws/aws-sdk-go-v2/aws" "github.com/aws/aws-sdk-go-v2/service/ses" "github.com/aws/aws-sdk-go-v2/service/ses/types"