mirror of
https://github.com/wassname/jaxtyping.git
synced 2026-09-10 12:14:04 +08:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
39439c2790 | ||
|
|
6202dcc639 |
+12
-2
@@ -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"
|
||||||
|
|||||||
@@ -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")
|
||||||
|
|||||||
@@ -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
@@ -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()
|
||||||
|
|||||||
Reference in New Issue
Block a user