mirror of
https://github.com/exo-explore/exo.git
synced 2026-04-18 13:00:59 -04:00
59669c1168
## Motivation The timings in the batch generator are a little optimistic; a minor change is needed to make them more correct. ## Changes Include the time spent in the API in the generation tps and make sure to send all requests simultaneously
37 lines
918 B
Python
37 lines
918 B
Python
import asyncio
|
|
|
|
import pytest
|
|
from exo_pyo3_bindings import (
|
|
Keypair,
|
|
NetworkingHandle,
|
|
NoPeersSubscribedToTopicError,
|
|
PyFromSwarm,
|
|
)
|
|
|
|
|
|
@pytest.mark.asyncio
|
|
async def test_sleep_on_multiple_items() -> None:
|
|
print("PYTHON: starting handle")
|
|
h = NetworkingHandle(Keypair.generate(), [], 0)
|
|
|
|
rt = asyncio.create_task(_await_recv(h))
|
|
|
|
# sleep for 4 ticks
|
|
for i in range(4):
|
|
await asyncio.sleep(1)
|
|
|
|
try:
|
|
await h.gossipsub_publish("topic", b"somehting or other")
|
|
except NoPeersSubscribedToTopicError as e:
|
|
print("caught it", e)
|
|
|
|
|
|
async def _await_recv(h: NetworkingHandle):
|
|
while True:
|
|
event = await h.recv()
|
|
match event:
|
|
case PyFromSwarm.Connection() as c:
|
|
print(f"PYTHON: connection update: {c}")
|
|
case PyFromSwarm.Message() as m:
|
|
print(f"PYTHON: message: {m}")
|