add caching validation

Author: David Andersson

.gitignore

@@ -22,3 +22,4 @@ venv36
 coverage.xml
 docs/source/_*
 __pycache__
+__open_alchemy_*_cache__

open_alchemy/__init__.py

@@ -64,7 +64,7 @@ def init_model_factory(
     schemas = components.get("schemas", {})
 
     # Pre-processing schemas
-    _schemas_module.process(schemas=schemas)
+    _schemas_module.process(schemas=schemas, spec_filename=spec_path)
 
     # Getting artifacts
     schemas_artifacts = _schemas_artifacts.get_from_schemas(

open_alchemy/schemas/__init__.py

@@ -1,13 +1,17 @@
 """Performs operations on the schemas to prepare them for further processing."""
 
+import typing
+
 from .. import types as _types
 from . import association
 from . import backref
 from . import foreign_key
 from . import validation
 
 
-def process(*, schemas: _types.Schemas) -> None:
+def process(
+    *, schemas: _types.Schemas, spec_filename: typing.Optional[str] = None
+) -> None:
     """
     Pre-process schemas.
 
@@ -18,7 +22,7 @@ def process(*, schemas: _types.Schemas) -> None:
         schemas: The schemas to pre-process in place.
 
     """
-    validation.process(schemas=schemas)
+    validation.process(schemas=schemas, spec_filename=spec_filename)
     backref.process(schemas=schemas)
     foreign_key.process(schemas=schemas)
     association.process(schemas=schemas)

tests/open_alchemy/integration/test_init.py

@@ -8,6 +8,7 @@
 import yaml
 
 import open_alchemy
+from open_alchemy import cache
 from open_alchemy.facades.sqlalchemy import types as sqlalchemy_types
 
 
@@ -236,6 +237,9 @@ def test_init_json(engine, sessionmaker, tmp_path):
     queried_model = session.query(model).first()
     assert queried_model.column == value
 
+    # Checking for cache
+    assert cache.schemas_valid(str(spec_file)) is True
+
 
 @pytest.mark.integration
 def test_init_json_remote(engine, sessionmaker, tmp_path, _clean_remote_schemas_store):
@@ -315,6 +319,9 @@ def test_init_yaml(engine, sessionmaker, tmp_path):
     queried_model = session.query(model).first()
     assert queried_model.column == value
 
+    # Checking for cache
+    assert cache.schemas_valid(str(spec_file)) is True
+
 
 @pytest.mark.integration
 def test_init_yaml_remote(engine, sessionmaker, tmp_path, _clean_remote_schemas_store):