Compare commits

..
2 Commits
Author SHA1 Message Date
Patrick Kidger 39439c2790 More fixes (#27)
* Edge-case doc fixes for parameterising types with PyTrees or AbstractDtypes

* Fixes for threading

* version bump
2022-09-20 15:12:21 -07:00
Patrick Kidger 6202dcc639 doc fix (#26) 2022-09-19 23:30:29 -07:00
4 changed files with 72 additions and 14 deletions
+12 -2
View File
@@ -17,7 +17,17 @@
# IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN # IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
# CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. # CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
from jax.numpy import ndarray as Array import typing
if getattr(typing, "GENERATING_DOCUMENTATION", False):
class Array:
pass
Array.__module__ = "builtins"
else:
from jax.numpy import ndarray as Array
from .array_types import ( from .array_types import (
AbstractArray, AbstractArray,
@@ -53,4 +63,4 @@ from .import_hook import install_import_hook
from .pytree_type import PyTree from .pytree_type import PyTree
__version__ = "0.2.2" __version__ = "0.2.4"
+13 -5
View File
@@ -19,6 +19,7 @@
import enum import enum
import functools as ft import functools as ft
import typing
from typing import Any, Dict, List, NoReturn, Optional, Tuple, TYPE_CHECKING, Union from typing import Any, Dict, List, NoReturn, Optional, Tuple, TYPE_CHECKING, Union
from typing_extensions import Literal from typing_extensions import Literal
@@ -149,14 +150,15 @@ class _MetaAbstractArray(type):
if cls.dtypes is not _any_dtype and dtype not in cls.dtypes: if cls.dtypes is not _any_dtype and dtype not in cls.dtypes:
return False return False
if len(storage.memo_stack) == 0: temp_memo = not hasattr(storage, "memo_stack") or len(storage.memo_stack) == 0
if temp_memo:
# `isinstance` happening outside any @jaxtyped decorators, e.g. at the # `isinstance` happening outside any @jaxtyped decorators, e.g. at the
# global scope. In this case just create a temporary memo, since we're not # global scope. In this case just create a temporary memo, since we're not
# going to be comparing against any stored values anyway. # going to be comparing against any stored values anyway.
single_memo = {} single_memo = {}
variadic_memo = {} variadic_memo = {}
variadic_broadcast_memo = {} variadic_broadcast_memo = {}
temp_memo = True
else: else:
single_memo, variadic_memo, variadic_broadcast_memo = storage.memo_stack[-1] single_memo, variadic_memo, variadic_broadcast_memo = storage.memo_stack[-1]
# Make a copy so we don't mutate the original memo during the shape check. # Make a copy so we don't mutate the original memo during the shape check.
@@ -385,7 +387,7 @@ class _MetaAbstractDtype(type):
if _array_name_format == "dtype_and_shape": if _array_name_format == "dtype_and_shape":
name = f"{cls.__name__}[{array_type.__name__}, '{dim_str}']" name = f"{cls.__name__}[{array_type.__name__}, '{dim_str}']"
elif _array_name_format == "array": elif _array_name_format == "array":
name = "Array" name = array_type.__name__
else: else:
raise ValueError(f"array_name_format {_array_name_format} not recognised") raise ValueError(f"array_name_format {_array_name_format} not recognised")
out = _MetaAbstractArray( out = _MetaAbstractArray(
@@ -398,7 +400,10 @@ class _MetaAbstractDtype(type):
index_variadic=index_variadic, index_variadic=index_variadic,
), ),
) )
out.__module__ = "jaxtyping" if getattr(typing, "GENERATING_DOCUMENTATION", False):
out.__module__ = "builtins"
else:
out.__module__ = "jaxtyping"
return out return out
@@ -470,7 +475,10 @@ else:
_Cls.__name__ = name _Cls.__name__ = name
_Cls.__qualname__ = name _Cls.__qualname__ = name
_Cls.__module__ = "jaxtyping" if getattr(typing, "GENERATING_DOCUMENTATION", False):
_Cls.__module__ = "builtins"
else:
_Cls.__module__ = "jaxtyping"
return _Cls return _Cls
UInt8 = _make_dtype(_uint8, "UInt8") UInt8 = _make_dtype(_uint8, "UInt8")
+20 -5
View File
@@ -18,7 +18,9 @@
# CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. # CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
import functools as ft import functools as ft
from typing import Generic, TypeVar import typing
from typing import Generic, TYPE_CHECKING, TypeVar
from typing_extensions import Protocol
import jax import jax
import typeguard import typeguard
@@ -51,7 +53,10 @@ class _MetaPyTree(type):
def __getitem__(cls, item): def __getitem__(cls, item):
name = str(_FakePyTree[item]) name = str(_FakePyTree[item])
out = _MetaSubscriptPyTree(name, (), {"leaftype": item}) out = _MetaSubscriptPyTree(name, (), {"leaftype": item})
out.__module__ = "jaxtyping" if getattr(typing, "GENERATING_DOCUMENTATION", False):
out.__module__ = "builtins"
else:
out.__module__ = "jaxtyping"
return out return out
@@ -82,8 +87,18 @@ class _MetaSubscriptPyTree(type):
return all(map(is_leaftype, leaves)) return all(map(is_leaftype, leaves))
PyTree = _MetaPyTree("PyTree", (), {}) if TYPE_CHECKING:
PyTree.__module__ = "jaxtyping" # Work around pytype bug #1288
# pytype: skip-file
class PyTree(Protocol[_T]):
pass
else:
PyTree = _MetaPyTree("PyTree", (), {})
if getattr(typing, "GENERATING_DOCUMENTATION", False):
PyTree.__module__ = "builtins"
else:
PyTree.__module__ = "jaxtyping"
# Can't do `class PyTree(Generic[_T]): ...` because we need to override the # Can't do `class PyTree(Generic[_T]): ...` because we need to override the
# instancecheck for PyTree[foo], but we subclassing # instancecheck for PyTree[foo], but subclassing
# `type(Generic[int])`, i.e. `typing._GenericAlias` is disallowed. # `type(Generic[int])`, i.e. `typing._GenericAlias` is disallowed.
+27 -2
View File
@@ -25,7 +25,22 @@ from typeguard import typechecked
from jaxtyping import Array, Float, jaxtyped from jaxtyping import Array, Float, jaxtyped
def test_threading(): class _ErrorableThread(threading.Thread):
def run(self):
try:
super().run()
except Exception as e:
self.exc = e
finally:
del self._target, self._args, self._kwargs
def join(self, timeout=None):
super().join(timeout)
if hasattr(self, "exc"):
raise self.exc
def test_threading_jaxtyped():
@jaxtyped @jaxtyped
@typechecked @typechecked
def add(x: Float[Array, "a b"], y: Float[Array, "a b"]) -> Float[Array, "a b"]: def add(x: Float[Array, "a b"], y: Float[Array, "a b"]) -> Float[Array, "a b"]:
@@ -36,6 +51,16 @@ def test_threading():
b = jnp.array([[2.0, 3.0]]) b = jnp.array([[2.0, 3.0]])
add(a, b) add(a, b)
thread = threading.Thread(target=run) thread = _ErrorableThread(target=run)
thread.start()
thread.join()
def test_threading_nojaxtyped():
def run():
a = jnp.array([[1.0, 2.0]])
assert isinstance(a, Float[Array, "..."])
thread = _ErrorableThread(target=run)
thread.start() thread.start()
thread.join() thread.join()