Increases times and removes comment

flow/activities/flowable.go

@@ -672,19 +672,25 @@ func (a *FlowableActivity) SendWALHeartbeat(ctx context.Context, config *protos.
 		return fmt.Errorf("failed to get destination connector: %w", err)
 	}
 	defer connectors.CloseConnector(srcConn)
-
-	ticker := time.NewTicker(10 * time.Second)
+	log.WithFields(log.Fields{"flowName": config.FlowJobName}).Info("sending walheartbeat every 10 minutes")
+	ticker := time.NewTicker(10 * time.Minute)
 	for {
 		select {
 		case <-ctx.Done():
-			log.Info("context is done, exiting wal heartbeat send loop")
+			log.WithFields(
+				log.Fields{
+					"flowName": config.FlowJobName,
+				}).Info("context is done, exiting wal heartbeat send loop")
 			return nil
 		case <-ticker.C:
 			err = srcConn.SendWALHeartbeat()
 			if err != nil {
 				return fmt.Errorf("failed to send WAL heartbeat: %w", err)
 			}
-			log.Info("sent wal heartbeat")
+			log.WithFields(
+				log.Fields{
+					"flowName": config.FlowJobName,
+				}).Info("sent wal heartbeat")
 		}
 	}
 }

flow/workflows/cdc_flow.go

@@ -258,10 +258,9 @@ func CDCFlowWorkflowWithConfig(
 
 	heartbeatCancelCtx, cancelHeartbeat := workflow.WithCancel(ctx)
 	walHeartbeatCtx := workflow.WithActivityOptions(heartbeatCancelCtx, workflow.ActivityOptions{
-		StartToCloseTimeout: 5 * time.Minute,
+		StartToCloseTimeout: 7 * 24 * time.Hour,
 	})
 	workflow.ExecuteActivity(walHeartbeatCtx, flowable.SendWALHeartbeat, cfg)
-	//walHeartbeatFuture.Get(ctx, nil)
 
 	syncFlowOptions := &protos.SyncFlowOptions{
 		BatchSize: int32(limits.MaxBatchSize),