diff --git a/src/results_cache.py b/src/results_cache.py index a0c9188..01c1aed 100644 --- a/src/results_cache.py +++ b/src/results_cache.py @@ -41,7 +41,7 @@ def get_lookup_query_key(self, workflow, query_graph): return json.dumps(keydict, sort_keys=True) def get_lookup_result(self, workflow, query_graph): - key = self.get_query_key(workflow, query_graph) + key = self.get_lookup_query_key(workflow, query_graph) result = self.redis.get(key) if result is not None: result = json.loads(gzip.decompress(result)) @@ -49,7 +49,7 @@ def get_lookup_result(self, workflow, query_graph): def set_lookup_result(self, workflow, query_graph, final_answer): - key = self.get_query_key(workflow, query_graph) + key = self.get_lookup_query_key(workflow, query_graph) self.redis.set(key, gzip.compress(json.dumps(final_answer).encode()))