How To Use
Running a client and using the subnet required connecting to the DHT as a client and running the session manager.
config = ClientConfig()
config.initial_peers = BOOTNODES
config.update_period = 60
dht = DHT(
initial_peers=config.initial_peers,
identity_path=IDENTITY_PATH,
start=True,
num_workers=8,
client_mode=True,
startup_timeout=config.daemon_startup_timeout,
announce_maddrs=ANNOUNCE_MADDRS_LIST
)
remote_manager = RemoteManager(
config=config,
dht=dht,
)
manager = SessionManager(remote_manager=remote_manager)
# Async generator example
async with manager.session() as session:
async for output in session.run_task():
# Single response example
async with manager.session() as session:
result = session.run_task()
Last updated