update processSortedSet to use withScores

This commit is contained in:
Barış Soner Uşaklı
2018-09-24 16:57:19 -04:00
committed by GitHub
parent cf75c79611
commit 5a69f979a8

View File

@@ -697,7 +697,7 @@ DELETE FROM "legacy_zset" z
var batchSize = (options || {}).batch || 100;
var query = client.query(new Cursor(`
SELECT z."value" v
SELECT z."value", z."score" v
FROM "legacy_object_live" o
INNER JOIN "legacy_zset" z
ON o."_key" = z."_key"
@@ -716,7 +716,7 @@ SELECT z."value" v
}
rows = rows.map(function (row) {
return row.v;
return options.withScores ? row : row.v;
});
process(rows, function (err) {