Remove cache init function

Author: kris-gaudel

pyiceberg/manifest.py

@@ -893,29 +893,15 @@ def __hash__(self) -> int:
 
 
 _DEFAULT_MANIFEST_CACHE_SIZE = 128
+_manifest_cache_size = Config().get_int("manifest-cache-size") or _DEFAULT_MANIFEST_CACHE_SIZE
 _manifest_cache_lock = threading.RLock()
-
-
-def _init_manifest_cache() -> LRUCache[str, ManifestFile] | None:
-    """Initialize the manifest cache from config."""
-    manifest_cache_size = Config().get_int("manifest-cache-size")
-    if manifest_cache_size is None:
-        manifest_cache_size = _DEFAULT_MANIFEST_CACHE_SIZE
-    if manifest_cache_size < 0:
-        raise ValueError(f"manifest-cache-size must be >= 0. Current value: {manifest_cache_size}")
-    if manifest_cache_size == 0:
-        return None
-    return LRUCache(maxsize=manifest_cache_size)
-
-
-_manifest_cache = _init_manifest_cache()
+_manifest_cache: LRUCache[str, ManifestFile] = LRUCache(maxsize=_manifest_cache_size)
 
 
 def clear_manifest_cache() -> None:
-    """Clear the manifest cache. No-op if cache is disabled."""
-    if _manifest_cache is not None:
-        with _manifest_cache_lock:
-            _manifest_cache.clear()
+    """Clear the manifest cache."""
+    with _manifest_cache_lock:
+        _manifest_cache.clear()
 
 
 def _manifests(io: FileIO, manifest_list: str) -> tuple[ManifestFile, ...]:
@@ -945,18 +931,14 @@ def _manifests(io: FileIO, manifest_list: str) -> tuple[ManifestFile, ...]:
     file = io.new_input(manifest_list)
     manifest_files = list(read_manifest_list(file))
 
-    if _manifest_cache is None:
-        return tuple(manifest_files)
-
     result = []
     with _manifest_cache_lock:
-        cache = _manifest_cache
         for manifest_file in manifest_files:
             manifest_path = manifest_file.manifest_path
-            if manifest_path in cache:
-                result.append(cache[manifest_path])
+            if manifest_path in _manifest_cache:
+                result.append(_manifest_cache[manifest_path])
             else:
-                cache[manifest_path] = manifest_file
+                _manifest_cache[manifest_path] = manifest_file
                 result.append(manifest_file)
 
     return tuple(result)

tests/utils/test_manifest.py

@@ -16,7 +16,6 @@
 # under the License.
 # pylint: disable=redefined-outer-name,arguments-renamed,fixme
 from tempfile import TemporaryDirectory
-from unittest import mock
 
 import fastavro
 import pytest
@@ -52,8 +51,6 @@
 
 @pytest.fixture(autouse=True)
 def reset_global_manifests_cache() -> None:
-    with manifest_module._manifest_cache_lock:
-        manifest_module._manifest_cache = manifest_module._init_manifest_cache()
     clear_manifest_cache()
 
 
@@ -1042,45 +1039,3 @@ def test_clear_manifest_cache() -> None:
         cache_after = manifest_module._manifest_cache
         assert cache_after is not None, "Cache should still be enabled after clear"
         assert len(cache_after) == 0, "Cache should be empty after clear"
-
-
-@pytest.mark.parametrize(
-    "env_vars,expected_enabled,expected_size",
-    [
-        ({}, True, 128),  # defaults
-        ({"PYICEBERG_MANIFEST_CACHE_SIZE": "64"}, True, 64),
-        ({"PYICEBERG_MANIFEST_CACHE_SIZE": "256"}, True, 256),
-        ({"PYICEBERG_MANIFEST_CACHE_SIZE": "0"}, False, 0),  # size=0 disables cache
-    ],
-)
-def test_manifest_cache_config_valid_values(env_vars: dict[str, str], expected_enabled: bool, expected_size: int) -> None:
-    """Test that valid config values are applied correctly."""
-    import os
-
-    with mock.patch.dict(os.environ, env_vars, clear=False):
-        with manifest_module._manifest_cache_lock:
-            manifest_module._manifest_cache = manifest_module._init_manifest_cache()
-        cache = manifest_module._manifest_cache
-
-        if expected_enabled:
-            assert cache is not None, "Cache should be enabled"
-            assert cache.maxsize == expected_size, f"Cache size should be {expected_size}"
-        else:
-            assert cache is None, "Cache should be disabled"
-
-
-@pytest.mark.parametrize(
-    "env_vars,expected_error_substring",
-    [
-        ({"PYICEBERG_MANIFEST_CACHE_SIZE": "abc"}, "manifest-cache-size should be an integer"),
-        ({"PYICEBERG_MANIFEST_CACHE_SIZE": "-5"}, "manifest-cache-size must be >= 0"),
-    ],
-)
-def test_manifest_cache_config_invalid_values(env_vars: dict[str, str], expected_error_substring: str) -> None:
-    """Test that invalid config values raise ValueError with appropriate message."""
-    import os
-
-    with mock.patch.dict(os.environ, env_vars, clear=False):
-        with pytest.raises(ValueError, match=expected_error_substring):
-            with manifest_module._manifest_cache_lock:
-                manifest_module._manifest_cache = manifest_module._init_manifest_cache()