Skip to content

Commit 04e153a

Browse files
Merge branch 'staging' into fix/zyzniewski/test_set_weights
2 parents f14b953 + 7c62606 commit 04e153a

File tree

4 files changed

+9
-7
lines changed

4 files changed

+9
-7
lines changed

.github/workflows/e2e-subtensor-tests.yaml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,11 @@ jobs:
8080
- name: Check-out repository
8181
uses: actions/checkout@v4
8282

83+
- name: Set up Python ${{ matrix.python-version }}
84+
uses: actions/setup-python@v5
85+
with:
86+
python-version: ${{ matrix.python-version }}
87+
8388
- name: Install uv
8489
uses: astral-sh/setup-uv@v4
8590

tests/e2e_tests/conftest.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ def try_start_docker():
164164
print("Docker wasn't run. Manual start may be required.")
165165
return False
166166

167-
container_name = f"test_local_chain_{str(time.time()).replace(".", "_")}"
167+
container_name = f"test_local_chain_{str(time.time()).replace('.', '_')}"
168168

169169
# Command to start container
170170
cmds = [

tests/e2e_tests/test_incentive.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,8 +84,7 @@ async def test_incentive(local_chain, subtensor, templates, alice_wallet, bob_wa
8484
async with templates.miner(bob_wallet, netuid):
8585
async with templates.validator(alice_wallet, netuid) as validator:
8686
# wait for the Validator to process and set_weights
87-
async with asyncio.timeout(60):
88-
await validator.set_weights.wait()
87+
await asyncio.wait_for(validator.set_weights.wait(), 60)
8988

9089
# Wait till new epoch
9190
await wait_interval(tempo, subtensor, netuid)

tests/e2e_tests/utils/e2e_test_utils.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -116,8 +116,7 @@ async def __aenter__(self):
116116

117117
self.__reader_task = asyncio.create_task(self._reader())
118118

119-
async with asyncio.timeout(30):
120-
await self.started.wait()
119+
await asyncio.wait_for(self.started.wait(), 30)
121120

122121
return self
123122

@@ -166,8 +165,7 @@ async def __aenter__(self):
166165

167166
self.__reader_task = asyncio.create_task(self._reader())
168167

169-
async with asyncio.timeout(30):
170-
await self.started.wait()
168+
await asyncio.wait_for(self.started.wait(), 30)
171169

172170
return self
173171

0 commit comments

Comments
 (0)