move peer fetching inside 10 minute wait cycle

flow/activities/flowable.go

@@ -706,23 +706,22 @@ func (a *FlowableActivity) SendWALHeartbeat(ctx context.Context) error {
 	sendTimeout := 10 * time.Minute
 	ticker := time.NewTicker(sendTimeout)
 	defer ticker.Stop()
-
-	pgPeers, err := getPostgresPeerConfigs(ctx)
-	if err != nil {
-		if strings.Contains(err.Error(), "does not exist") {
-			log.Warn("[sendwalheartbeat]: warning: peers table not found. Exiting")
-			return nil
-		}
-		return fmt.Errorf("error getting postgres peers: %w", err)
-	}
-
 	activity.RecordHeartbeat(ctx, "sending walheartbeat every 10 minutes")
 	for {
 		select {
 		case <-ctx.Done():
 			log.Info("context is done, exiting wal heartbeat send loop")
 			return nil
 		case <-ticker.C:
+			pgPeers, err := getPostgresPeerConfigs(ctx)
+			if err != nil {
+				if strings.Contains(err.Error(), "does not exist") {
+					log.Warn("[sendwalheartbeat]: warning: peers table not found. Exiting")
+					return nil
+				}
+				return fmt.Errorf("error getting postgres peers: %w", err)
+			}
+
 			command := `
 				BEGIN;
 				DROP aggregate IF EXISTS PEERDB_EPHEMERAL_HEARTBEAT(float4);