Skip to content

Commit

Permalink
chore: remove extra activity info from body
Browse files Browse the repository at this point in the history
  • Loading branch information
iamKunalGupta committed Mar 4, 2024
1 parent 1286635 commit a616dc5
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions flow/alerting/alerting.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,15 +7,13 @@ import (
"log/slog"
"time"

Check failure on line 9 in flow/alerting/alerting.go

View workflow job for this annotation

GitHub Actions / lint

File is not `gci`-ed with --skip-generated -s standard -s prefix(github.com/PeerDB-io) -s default (gci)
"github.com/jackc/pgx/v5"
"github.com/jackc/pgx/v5/pgxpool"
"go.temporal.io/sdk/activity"

"github.com/PeerDB-io/peer-flow/dynamicconf"
"github.com/PeerDB-io/peer-flow/generated/protos"
"github.com/PeerDB-io/peer-flow/logger"
"github.com/PeerDB-io/peer-flow/peerdbenv"
"github.com/PeerDB-io/peer-flow/shared/telemetry"
"github.com/jackc/pgx/v5"

Check failure on line 15 in flow/alerting/alerting.go

View workflow job for this annotation

GitHub Actions / lint

File is not `gci`-ed with --skip-generated -s standard -s prefix(github.com/PeerDB-io) -s default (gci)
"github.com/jackc/pgx/v5/pgxpool"
)

// alerting service, no cool name :(
Expand Down Expand Up @@ -211,7 +209,7 @@ func (a *Alerter) checkAndAddAlertToCatalog(ctx context.Context, alertKey string
func (a *Alerter) sendTelemetryMessage(ctx context.Context, flowName string, more string, level telemetry.Level) {
if a.telemetrySender != nil {
details := fmt.Sprintf("[%s] %s", flowName, more)
_, err := a.telemetrySender.SendMessage(ctx, details, fmt.Sprintf("%s\n%+v", details, activity.GetInfo(ctx)), telemetry.Attributes{
_, err := a.telemetrySender.SendMessage(ctx, details, details, telemetry.Attributes{
Level: level,
DeploymentUID: peerdbenv.PeerDBDeploymentUID(),
Tags: []string{flowName},
Expand Down

0 comments on commit a616dc5

Please sign in to comment.