Handle error if cached file was deleted concurrently

Wrap cache file read in try-except to handle race condition where
another async task deletes the file between validation and lock
acquisition.
Automatically retry with force=True to trigger re-download.

Signed-off-by: Marcel Bochtler <[email protected]>

Author: MarcelBochtler

src/python_inspector/utils_pypi.py

@@ -1760,9 +1760,24 @@ async def get(
         else:
             if TRACE_DEEP:
                 print(f"        FILE CACHE HIT: {path_or_url}")
-            # also lock on read to avoid race conditions
-            with lockfile.FileLock(lock_file).locked(timeout=PYINSP_CACHE_LOCK_TIMEOUT):
-                return await get_local_file_content(path=cached, as_text=as_text), cached
+
+            # File passed validation, lock and read
+            # Handle race condition where file might be deleted between validation and lock
+            try:
+                with lockfile.FileLock(lock_file).locked(timeout=PYINSP_CACHE_LOCK_TIMEOUT):
+                    return await get_local_file_content(path=cached, as_text=as_text), cached
+            except FileNotFoundError:
+                # File was deleted by another task after validation - retry with force.
+                if TRACE_DEEP:
+                    print(f"        FILE VANISHED after validation, re-downloading: {path_or_url}")
+                return await self.get(
+                    credentials=credentials,
+                    path_or_url=path_or_url,
+                    as_text=as_text,
+                    force=True,
+                    verbose=verbose,
+                    echo_func=echo_func,
+                )
 
 
 CACHE = Cache()