fix(core): Handle reading task results from previous redis delegate (#…

…2484)
spinnaker · Apr 5, 2018 · 0f8501f · 0f8501f
1 parent 44b9b18
commit 0f8501f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/groovy/com/netflix/spinnaker/clouddriver/data/task/jedis/RedisTaskRepository.java b/...rc/main/groovy/com/netflix/spinnaker/clouddriver/data/task/jedis/RedisTaskRepository.java
@@ -250,7 +250,7 @@ public void addResultObjects(List<Object> objects, JedisTask task) {
   public List<Object> getResultObjects(JedisTask task) {
     String resultId = "taskResult:" + task.getId();
 
-    return retry(() -> redisClientDelegate.withCommandsClient(client -> {
+    return retry(() -> clientForTask(task).withCommandsClient(client -> {
       return client.lrange(resultId, 0, -1);
     }), format("Getting results for task %s", task.getId()))
       .stream()