art-dag/celery
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix cache lookup to work across processes

Browse Source 
cache_manager.py:
- get_by_content_hash() now tries direct cache.get(content_hash)
  since uploads use content_hash as node_id
- This works even if cache index hasn't been reloaded

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
gilesb
2026-01-08 02:02:47 +00:00
parent 13b93ab17c
commit 3e12596dbf
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cache_manager.py
View File

@@ -250,6 +250,14 @@ class L1CacheManager:
if path and path.exists(): if path and path.exists():
return path return path
# For uploads, node_id == content_hash, so try direct lookup
# This works even if cache index hasn't been reloaded
path = self.cache.get(content_hash)
if path and path.exists():
self._content_index[content_hash] = content_hash
self._save_content_index()
return path
# Scan cache entries (fallback for new structure) # Scan cache entries (fallback for new structure)
entry = self.cache.find_by_content_hash(content_hash) entry = self.cache.find_by_content_hash(content_hash)
if entry and entry.output_path.exists(): if entry and entry.output_path.exists():