feat: add error handling for cache retrieval in CachedTaskWorker

provos · Feb 6, 2025 · de58729 · de58729
1 parent 1e2956b
commit de58729
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/planai/cached_task.py b/src/planai/cached_task.py
@@ -41,7 +41,11 @@ def _pre_consume_work(self, task: Task):
             self.pre_consume_work(task)
 
             cache_key = self._get_cache_key(task)
-            result = self._cache.get(cache_key)
+            try:
+                result = self._cache.get(cache_key)
+            except Exception as e:
+                logging.error("Error getting cache key %s: %s", cache_key, str(e))
+                result = None
 
             if result is not None:
                 cached_results, _ = result