diff --git a/executor/app/src/compute_horde_executor/executor/management/commands/run_executor.py b/executor/app/src/compute_horde_executor/executor/management/commands/run_executor.py index 7719fbf60..3e520089f 100644 --- a/executor/app/src/compute_horde_executor/executor/management/commands/run_executor.py +++ b/executor/app/src/compute_horde_executor/executor/management/commands/run_executor.py @@ -70,7 +70,7 @@ def __init__(self, loop: asyncio.AbstractEventLoop, miner_address: str, token: s self.full_payload_lock = asyncio.Lock() def miner_url(self) -> str: - return f'{self.miner_address}/v0/executor_interface/{self.token}' + return f'{self.miner_address}/v0.1/executor_interface/{self.token}' def accepted_request_type(self) -> type[BaseRequest]: return BaseMinerRequest diff --git a/miner/app/src/compute_horde_miner/asgi.py b/miner/app/src/compute_horde_miner/asgi.py index f2877a800..882df439b 100644 --- a/miner/app/src/compute_horde_miner/asgi.py +++ b/miner/app/src/compute_horde_miner/asgi.py @@ -19,8 +19,8 @@ re_path(r'.*', get_asgi_application()), ]), 'websocket': URLRouter([ - path('v0/validator_interface/', MinerValidatorConsumer.as_asgi()), - path('v0/executor_interface/', MinerExecutorConsumer.as_asgi()), + path('v0.1/validator_interface/', MinerValidatorConsumer.as_asgi()), + path('v0.1/executor_interface/', MinerExecutorConsumer.as_asgi()), ]), }) diff --git a/miner/app/src/compute_horde_miner/miner/tests/executor_manager.py b/miner/app/src/compute_horde_miner/miner/tests/executor_manager.py index b355b9639..0cddc573d 100644 --- a/miner/app/src/compute_horde_miner/miner/tests/executor_manager.py +++ b/miner/app/src/compute_horde_miner/miner/tests/executor_manager.py @@ -10,7 +10,7 @@ async def fake_executor(token): - communicator = WebsocketCommunicator(asgi.application, f"v0/executor_interface/{token}") + communicator = WebsocketCommunicator(asgi.application, f"v0.1/executor_interface/{token}") connected, _ = await communicator.connect() assert connected response = await communicator.receive_json_from(timeout=WEBSOCKET_TIMEOUT) diff --git a/miner/app/src/compute_horde_miner/miner/tests/integration/test_mocked_executor_manager.py b/miner/app/src/compute_horde_miner/miner/tests/integration/test_mocked_executor_manager.py index c763d37fc..86630168c 100644 --- a/miner/app/src/compute_horde_miner/miner/tests/integration/test_mocked_executor_manager.py +++ b/miner/app/src/compute_horde_miner/miner/tests/integration/test_mocked_executor_manager.py @@ -19,7 +19,7 @@ async def test_main_loop(): job_uuid = str(uuid.uuid4()) fake_executor.job_uuid = job_uuid - communicator = WebsocketCommunicator(asgi.application, f"v0/validator_interface/{validator_key}") + communicator = WebsocketCommunicator(asgi.application, f"v0.1/validator_interface/{validator_key}") connected, _ = await communicator.connect() assert connected await communicator.send_json_to({ diff --git a/tests/integration_tests/test_miner_on_dev_executor_manager.py b/tests/integration_tests/test_miner_on_dev_executor_manager.py index cc4d2119b..34d798408 100644 --- a/tests/integration_tests/test_miner_on_dev_executor_manager.py +++ b/tests/integration_tests/test_miner_on_dev_executor_manager.py @@ -84,7 +84,7 @@ async def test_echo_image(self): zip_contents = in_memory_output.read() base64_zipfile = base64.b64encode(zip_contents).decode() - async with websockets.connect(f'ws://localhost:8045/v0/validator_interface/{validator_key}') as ws: + async with websockets.connect(f'ws://localhost:8045/v0.1/validator_interface/{validator_key}') as ws: await ws.send(json.dumps({ "message_type": "V0AuthenticateRequest", "payload": { diff --git a/validator/app/src/compute_horde_validator/validator/synthetic_jobs/utils.py b/validator/app/src/compute_horde_validator/validator/synthetic_jobs/utils.py index 14cdeb349..7938817d0 100644 --- a/validator/app/src/compute_horde_validator/validator/synthetic_jobs/utils.py +++ b/validator/app/src/compute_horde_validator/validator/synthetic_jobs/utils.py @@ -56,7 +56,7 @@ def __init__(self, loop: asyncio.AbstractEventLoop, miner_address: str, my_hotke self.miner_finished_or_failed_timestamp: int = 0 def miner_url(self) -> str: - return f'ws://{self.miner_address}:{self.miner_port}/v0/validator_interface/{self.my_hotkey}' + return f'ws://{self.miner_address}:{self.miner_port}/v0.1/validator_interface/{self.my_hotkey}' def accepted_request_type(self) -> type[BaseRequest]: return BaseMinerRequest