From 5a69f979a834a126c197c28375ff31ccd65a1d47 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Bar=C4=B1=C5=9F=20Soner=20U=C5=9Fakl=C4=B1?=
 <barisusakli@gmail.com>
Date: Mon, 24 Sep 2018 16:57:19 -0400
Subject: [PATCH] update processSortedSet to use withScores

---
 src/database/postgres/sorted.js | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/database/postgres/sorted.js b/src/database/postgres/sorted.js
index 7f136ac653..5ba554a57e 100644
--- a/src/database/postgres/sorted.js
+++ b/src/database/postgres/sorted.js
@@ -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) {