Fix runtime instantation of objects that don't define `__class_getite…

…m__`

trio/_core/_tests/test_guest_mode.py

@@ -20,6 +20,7 @@
     Callable,
     NoReturn,
     TypeVar,
+    cast,
 )
 
 import pytest
@@ -458,7 +459,7 @@ async def trio_main() -> str:
         print("trio_main!")
 
         to_trio, from_aio = trio.open_memory_channel[int](float("inf"))
-        from_trio = asyncio.Queue[int]()
+        from_trio = cast("asyncio.Queue[int]", asyncio.Queue)()
 
         aio_task = asyncio.ensure_future(aio_pingpong(from_trio, to_trio))
 

trio/_core/_tests/test_thread_cache.py

@@ -4,7 +4,7 @@
 import time
 from contextlib import contextmanager
 from queue import Queue
-from typing import Iterator, NoReturn
+from typing import Iterator, NoReturn, cast
 
 import pytest
 from outcome import Outcome
@@ -16,7 +16,7 @@
 
 
 def test_thread_cache_basics() -> None:
-    q = Queue[Outcome]()
+    q = cast("Queue[Outcome]", Queue)()
 
     def fn() -> NoReturn:
         raise RuntimeError("hi")
@@ -41,7 +41,7 @@ def __call__(self) -> int:
         def __del__(self) -> None:
             res[0] = True
 
-    q = Queue[Outcome]()
+    q = cast("Queue[Outcome]", Queue)()
 
     def deliver(outcome: Outcome) -> None:
         q.put(outcome)
@@ -64,7 +64,7 @@ def test_spawning_new_thread_from_deliver_reuses_starting_thread() -> None:
 
     # Make sure there are a few threads running, so if we weren't LIFO then we
     # could grab the wrong one.
-    q = Queue[Outcome]()
+    q = cast("Queue[Outcome]", Queue)()
     COUNT = 5
     for _ in range(COUNT):
         start_thread_soon(lambda: time.sleep(1), lambda result: q.put(result))

trio/_tests/test_threads.py

@@ -20,6 +20,7 @@
     Type,
     TypeVar,
     Union,
+    cast,
 )
 
 import pytest
@@ -346,7 +347,7 @@ async def child(q: stdlib_queue.Queue[None], cancellable: bool) -> None:
             record.append("exit")
 
     record: list[str] = []
-    q = stdlib_queue.Queue[None]()
+    q = cast("stdlib_queue.Queue[None]", stdlib_queue.Queue)()
     async with _core.open_nursery() as nursery:
         nursery.start_soon(child, q, True)
         # Give it a chance to get started. (This is important because
@@ -394,8 +395,8 @@ def test_run_in_worker_thread_abandoned(
 ) -> None:
     monkeypatch.setattr(_core._thread_cache, "IDLE_TIMEOUT", 0.01)
 
-    q1 = stdlib_queue.Queue[None]()
-    q2 = stdlib_queue.Queue[threading.Thread]()
+    q1 = cast("stdlib_queue.Queue[None]", stdlib_queue.Queue)()
+    q2 = cast("stdlib_queue.Queue[threading.Thread]", stdlib_queue.Queue)()
 
     def thread_fn() -> None:
         q1.get()
@@ -918,7 +919,7 @@ def get_tid_then_reenter() -> int:
 
 
 async def test_from_thread_host_cancelled() -> None:
-    queue = stdlib_queue.Queue[bool]()
+    queue = cast("stdlib_queue.Queue[bool]", stdlib_queue.Queue)()
 
     def sync_check() -> None:
         from_thread_run_sync(cancel_scope.cancel)
@@ -977,7 +978,7 @@ async def async_time_bomb() -> None:
 
 
 async def test_from_thread_check_cancelled() -> None:
-    q = stdlib_queue.Queue[str]()
+    q = cast("stdlib_queue.Queue[str]", stdlib_queue.Queue)()
 
     async def child(cancellable: bool, scope: CancelScope) -> None:
         with scope:
@@ -1057,7 +1058,7 @@ def f() -> None:  # type: ignore[no-redef] # noqa: F811
 async def test_from_thread_check_cancelled_raises_in_foreign_threads() -> None:
     with pytest.raises(RuntimeError):
         from_thread_check_cancelled()
-    q = stdlib_queue.Queue[Outcome]()
+    q = cast("stdlib_queue.Queue[Outcome]", stdlib_queue.Queue)()
     _core.start_thread_soon(from_thread_check_cancelled, lambda _: q.put(_))
     with pytest.raises(RuntimeError):
         q.get(timeout=1).unwrap()