|
1 | 1 | import re
|
2 |
| -import threading |
3 | 2 | import time
|
4 | 3 | from dataclasses import dataclass
|
5 | 4 | from typing import Any, Optional, Tuple
|
6 | 5 | from unittest import IsolatedAsyncioTestCase
|
7 | 6 | from unittest.mock import AsyncMock, MagicMock, patch
|
8 | 7 |
|
9 |
| -import aiohttp |
10 | 8 | import fastapi
|
11 | 9 | import netaddr
|
12 | 10 | import pydantic
|
13 | 11 | import pytest
|
14 |
| -import uvicorn |
15 | 12 | from fastapi.testclient import TestClient
|
16 | 13 | from starlette.requests import Request
|
17 | 14 |
|
18 |
| -from bittensor.core.axon import Axon, AxonMiddleware, FastAPIThreadedServer |
| 15 | +from bittensor.core.axon import AxonMiddleware, Axon |
19 | 16 | from bittensor.core.errors import RunException
|
20 | 17 | from bittensor.core.settings import version_as_int
|
21 | 18 | from bittensor.core.stream import StreamingSynapse
|
@@ -768,45 +765,3 @@ async def forward_fn(synapse: streaming_synapse_cls):
|
768 | 765 | "computed_body_hash": "a7ffc6f8bf1ed76651c14756a061d662f580ff4de43b49fa82d80a4b80f8434a",
|
769 | 766 | },
|
770 | 767 | )
|
771 |
| - |
772 |
| - |
773 |
| -@pytest.mark.asyncio |
774 |
| -async def test_threaded_fastapi(): |
775 |
| - server_started = threading.Event() |
776 |
| - server_stopped = threading.Event() |
777 |
| - |
778 |
| - async def lifespan(app): |
779 |
| - server_started.set() |
780 |
| - yield |
781 |
| - server_stopped.set() |
782 |
| - |
783 |
| - app = fastapi.FastAPI( |
784 |
| - lifespan=lifespan, |
785 |
| - ) |
786 |
| - app.get("/")(lambda: "Hello World") |
787 |
| - |
788 |
| - server = FastAPIThreadedServer( |
789 |
| - uvicorn.Config( |
790 |
| - app, |
791 |
| - ), |
792 |
| - ) |
793 |
| - server.start() |
794 |
| - |
795 |
| - server_started.wait() |
796 |
| - |
797 |
| - assert server.is_running is True |
798 |
| - |
799 |
| - async with aiohttp.ClientSession( |
800 |
| - base_url="http://127.0.0.1:8000", |
801 |
| - ) as session: |
802 |
| - async with session.get("/") as response: |
803 |
| - assert await response.text() == '"Hello World"' |
804 |
| - |
805 |
| - server.stop() |
806 |
| - |
807 |
| - assert server.should_exit is True |
808 |
| - |
809 |
| - server_stopped.wait() |
810 |
| - |
811 |
| - with pytest.raises(aiohttp.ClientConnectorError): |
812 |
| - await session.get("/") |
0 commit comments