diff --git a/services/document-updater/app/coffee/RedisMigrationManager.coffee b/services/document-updater/app/coffee/RedisMigrationManager.coffee
index 553e707753..4978bf7e7b 100644
--- a/services/document-updater/app/coffee/RedisMigrationManager.coffee
+++ b/services/document-updater/app/coffee/RedisMigrationManager.coffee
@@ -106,7 +106,7 @@ class Multi
 			@migrationClient.findQueue @queueKey, (err, rclient) =>
 				return releaseLock(err) if err?
 				# add metric for updates
-				dest = (if rclient == @rclient_new then "new" else "old")
+				dest = (if rclient == @migrationClient.rclient_new then "new" else "old")
 				metrics.count "migration", @updates_count, 1, {status: "#{@migrationClient.migration_phase}-#{dest}"}
 				multi = rclient.multi()
 				for entry in @command_list