We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d4edece commit 6a7203bCopy full SHA for 6a7203b
1 file changed
receptor/entrypoints.py
@@ -11,6 +11,9 @@
11
12
def run_as_node(config):
13
async def node_keepalive():
14
+ # NOTE: I'm not really happy with this, I'd love to be able to await Peer(node).ping()
15
+ # and then verify the status under a timeout rather than just throw away the result and
16
+ # rely on the connection logic
17
for node_id in controller.receptor.router.get_nodes():
18
await controller.ping(node_id, expected_response=False)
19
absolute_call_time = (((int(controller.loop.time()) + 1) // config.node_keepalive_interval) + 1) * config.node_keepalive_interval
0 commit comments