From a616dc5f11c35dcfef1222d85c9ec61c018ee8f3 Mon Sep 17 00:00:00 2001 From: Kunal Gupta <39487888+iamKunalGupta@users.noreply.github.com> Date: Mon, 4 Mar 2024 23:00:40 +0530 Subject: [PATCH] chore: remove extra activity info from body --- flow/alerting/alerting.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/flow/alerting/alerting.go b/flow/alerting/alerting.go index 794d7e6039..1c086ec179 100644 --- a/flow/alerting/alerting.go +++ b/flow/alerting/alerting.go @@ -7,15 +7,13 @@ import ( "log/slog" "time" - "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" + "github.com/jackc/pgx/v5/pgxpool" ) // alerting service, no cool name :( @@ -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},