Fix typo in comment

pg-sharding · Mar 28, 2024 · a101743 · a101743
1 parent 11de040
commit a101743
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/datatransfers/data_transfers.go b/pkg/datatransfers/data_transfers.go
@@ -181,7 +181,7 @@ func copyData(ctx context.Context, from, to *pgx.Conn, fromId, toId string, krg
 	fromHost := strings.Split(fromShard.Hosts[0], ":")[0]
 	serverName := fmt.Sprintf("%s_%s_%s", strings.Split(toShard.Hosts[0], ":")[0], dbName, fromHost)
 	// create postgres_fdw server on receiving shard
-	// TODO find_master
+	// TODO find master
 	_, err := to.Exec(ctx, fmt.Sprintf(`CREATE server IF NOT EXISTS %s FOREIGN DATA WRAPPER postgres_fdw OPTIONS (dbname '%s', host '%s', port '%s')`, serverName, dbName, fromHost, strings.Split(fromShard.Hosts[0], ":")[1]))
 	if err != nil {
 		return err