fix error

PeerDB-io · Oct 16, 2023 · 7c941c9 · 7c941c9
1 parent c036c5b
commit 7c941c9
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -17,7 +17,6 @@ import (
 	"github.com/PeerDB-io/peer-flow/model"
 	cmap "github.com/orcaman/concurrent-map/v2"
 	log "github.com/sirupsen/logrus"
-	"go.temporal.io/sdk/activity"
 )
 
 type EventHubConnector struct {
@@ -131,8 +130,6 @@ func (c *EventHubConnector) processBatch(
 	ctx := context.Background()
 
 	tableNameRowsMapping := cmap.New[uint32]()
-	eventsPerHeartBeat := 1000
-
 	batchPerTopic := NewHubBatches(c.hubManager)
 	toJSONOpts := model.NewToJSONOptions(c.config.UnnestColumns)
 
@@ -173,10 +170,6 @@ func (c *EventHubConnector) processBatch(
 			return err
 		}
 
-		if i%eventsPerHeartBeat == 0 {
-			activity.RecordHeartbeat(ctx, fmt.Sprintf("sent %d records to hub: %s", i, topicName.ToString()))
-		}
-
 		if (i+1)%eventsPerBatch == 0 {
 			err := flushBatch()
 			if err != nil {