|
1 | 1 | import os
|
2 |
| -import asyncio |
3 | 2 | import bittensor as bt
|
| 3 | +import pytest |
4 | 4 |
|
5 |
| -use_async = (os.getenv("USE_ASYNC") == "1") or False |
6 | 5 | try:
|
7 | 6 | n = int(os.getenv("NUMBER_RUNS"))
|
8 | 7 | except TypeError:
|
|
16 | 15 | b_pre = 4920340
|
17 | 16 | b_post = 4920360
|
18 | 17 |
|
19 |
| -if use_async: |
20 |
| - st = bt.async_subtensor(network="local") |
21 |
| - |
22 |
| - async def main(): |
23 |
| - async with st: |
24 |
| - print("ss58 format:", st.substrate.ss58_format) |
25 |
| - print("current block (async):", await st.block) |
26 |
| - for i in range(n): |
27 |
| - s0 = await st.get_stake_for_coldkey(coldkey, block=b_post + i) |
28 |
| - print(f"at block {b_post + i}: {s0}") |
29 |
| - for i in range(n): |
30 |
| - s1 = ( |
31 |
| - await st.query_subtensor( |
32 |
| - "TotalColdkeyStake", block=b_pre + i, params=[coldkey] |
33 |
| - ) |
34 |
| - ).value |
35 |
| - print(f"at block {b_pre + i}: {s1}") |
36 |
| - for i in range(n): |
37 |
| - s2 = await st.get_stake_for_coldkey(coldkey, block=b_post + i) |
38 |
| - print(f"at block {b_post + i}: {s2}") |
39 |
| - |
40 |
| - asyncio.run(main()) |
41 |
| -else: |
42 |
| - st = bt.subtensor(network="local") |
43 |
| - print("ss58 format:", st.substrate.ss58_format) |
44 |
| - print("current block (sync):", st.block) |
45 |
| - st = bt.subtensor(network="local") |
46 |
| - for i in range(n): |
47 |
| - s0 = st.get_stake_for_coldkey(coldkey, block=b_post + i) |
48 |
| - print(f"at block {b_post + i}: {s0}") |
49 |
| - for i in range(n): |
50 |
| - s1 = st.query_subtensor("TotalColdkeyStake", b_pre + i, [coldkey]).value |
51 |
| - print(f"at block {b_pre + i}: {s1}") |
52 |
| - for i in range(n): |
53 |
| - s2 = st.get_stake_for_coldkey(coldkey, block=b_post + i) |
54 |
| - print(f"at block {b_post + i}: {s2}") |
| 18 | + |
| 19 | +@pytest.mark.asyncio |
| 20 | +async def test_async(): |
| 21 | + async with bt.async_subtensor("archive") as st: |
| 22 | + print("ss58 format:", st.substrate.ss58_format) |
| 23 | + print("current block (async):", await st.block) |
| 24 | + for i in range(n): |
| 25 | + s0 = await st.get_stake_for_coldkey(coldkey, block=b_post + i) |
| 26 | + print(f"at block {b_post + i}: {s0}") |
| 27 | + for i in range(n): |
| 28 | + s1 = ( |
| 29 | + await st.query_subtensor( |
| 30 | + "TotalColdkeyStake", block=b_pre + i, params=[coldkey] |
| 31 | + ) |
| 32 | + ).value |
| 33 | + print(f"at block {b_pre + i}: {s1}") |
| 34 | + for i in range(n): |
| 35 | + s2 = await st.get_stake_for_coldkey(coldkey, block=b_post + i) |
| 36 | + print(f"at block {b_post + i}: {s2}") |
| 37 | + |
| 38 | + |
| 39 | +def test_sync(): |
| 40 | + with bt.subtensor("archive") as st: |
| 41 | + print("ss58 format:", st.substrate.ss58_format) |
| 42 | + print("current block (sync):", st.block) |
| 43 | + for i in range(n): |
| 44 | + s0 = st.get_stake_for_coldkey(coldkey, block=b_post + i) |
| 45 | + print(f"at block {b_post + i}: {s0}") |
| 46 | + for i in range(n): |
| 47 | + s1 = st.query_subtensor("TotalColdkeyStake", b_pre + i, [coldkey]).value |
| 48 | + print(f"at block {b_pre + i}: {s1}") |
| 49 | + for i in range(n): |
| 50 | + s2 = st.get_stake_for_coldkey(coldkey, block=b_post + i) |
| 51 | + print(f"at block {b_post + i}: {s2}") |
0 commit comments