From 89e20089ce0679d9187edd4c44f38bc105bb387e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Philip=20Dub=C3=A9?= <philip@peerdb.io>
Date: Tue, 20 Feb 2024 15:22:34 +0000
Subject: [PATCH] replace sql.RawBytes with []byte

---
 flow/activities/flowable.go | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index 9636279e71..fd1cd325ac 100644
--- a/flow/activities/flowable.go
+++ b/flow/activities/flowable.go
@@ -11,7 +11,6 @@ import (
 	"time"
 
 	"github.com/jackc/pgx/v5"
-	"github.com/jackc/pgx/v5/pgtype"
 	"github.com/jackc/pgx/v5/pgxpool"
 	"go.temporal.io/sdk/activity"
 	"golang.org/x/sync/errgroup"
@@ -716,9 +715,9 @@ func (a *FlowableActivity) getPostgresPeerConfigs(ctx context.Context) ([]*proto
 		return nil, err
 	}
 
-	var peerName pgtype.Text
-	var peerOptions sql.RawBytes
 	return pgx.CollectRows(optionRows, func(row pgx.CollectableRow) (*protos.Peer, error) {
+		var peerName string
+		var peerOptions []byte
 		err := optionRows.Scan(&peerName, &peerOptions)
 		if err != nil {
 			return nil, err
@@ -729,7 +728,7 @@ func (a *FlowableActivity) getPostgresPeerConfigs(ctx context.Context) ([]*proto
 			return nil, unmarshalErr
 		}
 		return &protos.Peer{
-			Name:   peerName.String,
+			Name:   peerName,
 			Type:   protos.DBType_POSTGRES,
 			Config: &protos.Peer_PostgresConfig{PostgresConfig: &pgPeerConfig},
 		}, nil