"""Lazy imported module should not be loaded if never accessed."""
import test.test_lazy_import.data.basic_unused
self.assertNotIn("test.test_lazy_import.data.basic2", sys.modules)
- self.assertIn("test.test_lazy_import.data", sys.lazy_modules)
- self.assertEqual(sys.lazy_modules["test.test_lazy_import.data"], {"basic2"})
+ self.assertIn("test.test_lazy_import.data.basic2", sys.lazy_modules)
def test_sys_lazy_modules(self):
try:
self.assertFalse("test.test_lazy_import.data.basic2" in sys.modules)
self.assertIn("test.test_lazy_import.data", sys.lazy_modules)
- self.assertEqual(sys.lazy_modules["test.test_lazy_import.data"], {"basic2"})
+ self.assertIn("test.test_lazy_import.data.basic2", sys.lazy_modules)
test.test_lazy_import.data.basic_from_unused.basic2
self.assertNotIn("test.test_import.data", sys.lazy_modules)
self.assertIs(sys.get_lazy_imports_filter(), my_filter)
def test_lazy_modules_attribute_is_dict(self):
- """sys.lazy_modules should be a dict per PEP 810."""
- self.assertIsInstance(sys.lazy_modules, dict)
+ """sys.lazy_modules should be a set per PEP 810."""
+ self.assertIsInstance(sys.lazy_modules, set)
@support.requires_subprocess()
def test_lazy_modules_tracks_lazy_imports(self):
import sys
initial_count = len(sys.lazy_modules)
import test.test_lazy_import.data.basic_unused
- assert "test.test_lazy_import.data" in sys.lazy_modules
- assert sys.lazy_modules["test.test_lazy_import.data"] == {"basic2"}
+ assert "test.test_lazy_import.data.basic2" in sys.lazy_modules
assert len(sys.lazy_modules) > initial_count
print("OK")
""")
lazy import test.test_lazy_import.data.basic2
# Should be in lazy_modules after lazy import
- assert "test.test_lazy_import.data" in sys.lazy_modules
- assert sys.lazy_modules["test.test_lazy_import.data"] == {"basic2"}
+ assert "test.test_lazy_import.data.basic2" in sys.lazy_modules
assert len(sys.lazy_modules) > initial_count
# Trigger reification
_ = test.test_lazy_import.data.basic2.x
# Module should still be tracked (for diagnostics per PEP 810)
- assert "test.test_lazy_import.data" not in sys.lazy_modules
+ assert "test.test_lazy_import.data.basic2" not in sys.lazy_modules
print("OK")
""")
result = subprocess.run(
def test_lazy_modules_is_per_interpreter(self):
"""Each interpreter should have independent sys.lazy_modules."""
- # Basic test that sys.lazy_modules exists and is a dict
- self.assertIsInstance(sys.lazy_modules, dict)
+ # Basic test that sys.lazy_modules exists and is a set
+ self.assertIsInstance(sys.lazy_modules, set)
def test_lazy_module_without_children_is_tracked(self):
code = textwrap.dedent("""
assert "json" in sys.lazy_modules, (
f"expected 'json' in sys.lazy_modules, got {set(sys.lazy_modules)}"
)
- assert sys.lazy_modules["json"] == set(), (
- f"expected empty set for sys.lazy_modules['json'], "
- f"got {sys.lazy_modules['json']!r}"
- )
print("OK")
""")
assert_python_ok("-c", code)
t.join()
assert not errors, f"Errors: {errors}"
- assert isinstance(sys.lazy_modules, dict), "sys.lazy_modules is not a dict"
+ assert isinstance(sys.lazy_modules, set), "sys.lazy_modules is not a dict"
print("OK")
""")
(interp)->imports.modules_by_index
#define LAZY_MODULES(interp) \
(interp)->imports.lazy_modules
+#define LAZY_PENDING_SUBMODULES(interp) \
+ (interp)->imports.lazy_pending_submodules
#define IMPORTLIB(interp) \
(interp)->imports.importlib
#define OVERRIDE_MULTI_INTERP_EXTENSIONS_CHECK(interp) \
PyObject *
_PyImport_InitLazyModules(PyInterpreterState *interp)
{
- assert(LAZY_MODULES(interp) == NULL);
- LAZY_MODULES(interp) = PyDict_New();
+ assert(LAZY_MODULES(interp) == NULL &&
+ LAZY_PENDING_SUBMODULES(interp) == NULL);
+
+ LAZY_PENDING_SUBMODULES(interp) = PyDict_New();
+ LAZY_MODULES(interp) = PySet_New(0);
return LAZY_MODULES(interp);
}
_PyImport_ClearLazyModules(PyInterpreterState *interp)
{
Py_CLEAR(LAZY_MODULES(interp));
+ Py_CLEAR(LAZY_PENDING_SUBMODULES(interp));
}
static int
// ensure we have the set for the parent module name in sys.lazy_modules.
// Returns a new reference.
static PyObject *
-ensure_lazy_submodules(PyDictObject *lazy_modules, PyObject *parent)
+ensure_lazy_pending_submodules(PyDictObject *lazy_modules, PyObject *parent)
{
PyObject *lazy_submodules;
Py_BEGIN_CRITICAL_SECTION(lazy_modules);
return lazy_submodules;
}
+// Ensures that we have a LazyImportObject on the parent module for
+// all children modules which have been lazily imported. If the parent
+// module overrides the child attribute then the value is not replaced.
static int
register_lazy_on_parent(PyThreadState *tstate, PyObject *name,
PyObject *builtins)
PyObject *parent_dict = NULL;
PyInterpreterState *interp = tstate->interp;
- PyObject *lazy_modules = LAZY_MODULES(interp);
- assert(lazy_modules != NULL);
+ PyObject *lazy_pending_submodules = LAZY_PENDING_SUBMODULES(interp);
+ assert(lazy_pending_submodules != NULL);
Py_INCREF(name);
while (true) {
Py_ssize_t dot = PyUnicode_FindChar(name, '.', 0,
PyUnicode_GET_LENGTH(name), -1);
if (dot < 0) {
- PyObject *lazy_submodules = ensure_lazy_submodules(
- (PyDictObject *)lazy_modules, name);
+ PyObject *lazy_submodules = ensure_lazy_pending_submodules(
+ (PyDictObject *)lazy_pending_submodules, name);
if (lazy_submodules == NULL) {
goto done;
}
}
// Record the child as being lazily imported from the parent.
- PyObject *lazy_submodules = ensure_lazy_submodules(
- (PyDictObject *)lazy_modules, parent);
+ PyObject *lazy_submodules = ensure_lazy_pending_submodules(
+ (PyDictObject *)lazy_pending_submodules, parent);
if (lazy_submodules == NULL) {
goto done;
}
if (fromname == NULL) {
return -1;
}
+
+ // Add the module name to sys.lazy_modules set (PEP 810).
+ PyObject *lazy_modules = LAZY_MODULES(tstate->interp);
+ if (PySet_Add(lazy_modules, fromname) < 0) {
+ Py_DECREF(fromname);
+ return -1;
+ }
+
int res = register_lazy_on_parent(tstate, fromname, builtins);
Py_DECREF(fromname);
return res;
Py_DECREF(abs_name);
return NULL;
}
+
+ // Add the module name to sys.lazy_modules set (PEP 810).
+ PyObject *lazy_modules = LAZY_MODULES(tstate->interp);
+ if (PySet_Add(lazy_modules, abs_name) < 0) {
+ goto error;
+ }
+
if (fromlist && PyUnicode_Check(fromlist)) {
if (register_from_lazy_on_parent(tstate, abs_name, fromlist,
builtins) < 0) {
Py_CLEAR(IMPORTLIB(interp));
Py_CLEAR(IMPORT_FUNC(interp));
Py_CLEAR(LAZY_IMPORT_FUNC(interp));
+ Py_CLEAR(interp->imports.lazy_pending_submodules);
Py_CLEAR(interp->imports.lazy_modules);
Py_CLEAR(interp->imports.lazy_importing_modules);
Py_CLEAR(interp->imports.lazy_imports_filter);
PyThreadState *tstate = _PyThreadState_GET();
PyObject *module_dict = NULL;
PyObject *ret = NULL;
- PyObject *lazy_modules = LAZY_MODULES(tstate->interp);
- assert(lazy_modules != NULL);
+ PyObject *lazy_pending_modules = LAZY_PENDING_SUBMODULES(tstate->interp);
+ assert(lazy_pending_modules != NULL);
PyObject *lazy_submodules;
- if (PyDict_GetItemRef(lazy_modules, name, &lazy_submodules) < 0) {
+ if (PySet_Discard(LAZY_MODULES(tstate->interp), name) < 0) {
+ return NULL;
+ } else if (PyDict_GetItemRef(lazy_pending_modules, name, &lazy_submodules) < 0) {
return NULL;
}
else if (lazy_submodules == NULL) {
Py_END_CRITICAL_SECTION();
Py_DECREF(lazy_submodules);
- // once a module is imported it is removed from sys.lazy_modules
- if (PyDict_DelItem(lazy_modules, name) < 0) {
+ if (PyDict_DelItem(lazy_pending_modules, name) < 0) {
goto error;
}