This commit is contained in:
parent
8b7e6ca8bc
commit
fbd5f28d54
@ -74,7 +74,7 @@ func (s *Syncer) Process(ctx context.Context) error {
|
|||||||
|
|
||||||
kvRows, err := pgx.CollectRows(rows, func(row pgx.CollectableRow) (KVRow, error) {
|
kvRows, err := pgx.CollectRows(rows, func(row pgx.CollectableRow) (KVRow, error) {
|
||||||
var kvRow KVRow
|
var kvRow KVRow
|
||||||
err := row.Scan(&kvRow.Key, &kvRow.Value, &kvRow.Updated)
|
err := row.Scan(&kvRow.ID, &kvRow.Key, &kvRow.Value, &kvRow.Updated)
|
||||||
return kvRow, err
|
return kvRow, err
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user