update heartbeat for eventhub (#409)

PeerDB-io · Sep 21, 2023 · 39857d7 · 39857d7
1 parent c9a8830
commit 39857d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/eventhub/eventhub.go b/flow/connectors/eventhub/eventhub.go
@@ -96,7 +96,7 @@ func (c *EventHubConnector) InitializeTableSchema(req map[string]*protos.TableSc
 }
 
 func (c *EventHubConnector) SyncRecords(req *model.SyncRecordsRequest) (*model.SyncResponse, error) {
-	shutdown := utils.HeartbeatRoutine(c.ctx, 1*time.Minute, func() string {
+	shutdown := utils.HeartbeatRoutine(c.ctx, 10*time.Second, func() string {
 		return fmt.Sprintf("syncing records to eventhub with"+
 			" push parallelism %d and push batch size %d",
 			req.PushParallelism, req.PushBatchSize)