From 7813dd226b0fa083d3209fbd10b83a17d5159059 Mon Sep 17 00:00:00 2001 From: gufengc Date: Thu, 23 Oct 2025 17:54:10 +0800 Subject: [PATCH 1/3] chore(relay): add more relay server --- src/backend/server/scheduler_manage.py | 2 +- src/common/static_config.py | 8 +++++++ src/parallax/cli.py | 29 +++++++++++++++++++++++--- 3 files changed, 35 insertions(+), 4 deletions(-) diff --git a/src/backend/server/scheduler_manage.py b/src/backend/server/scheduler_manage.py index bdb78982..53b342e9 100644 --- a/src/backend/server/scheduler_manage.py +++ b/src/backend/server/scheduler_manage.py @@ -7,7 +7,7 @@ from backend.server.constants import NODE_STATUS_AVAILABLE, NODE_STATUS_WAITING from backend.server.rpc_connection_handler import RPCConnectionHandler from backend.server.static_config import get_model_info, get_node_join_command -from common.static_config import PUBLIC_INITIAL_PEERS, PUBLIC_RELAY_SERVERS +from parallax.cli import PUBLIC_INITIAL_PEERS, PUBLIC_RELAY_SERVERS from parallax.p2p.server import TransformerConnectionHandler from parallax_utils.logging_config import get_logger from scheduling.node import RequestSignal diff --git a/src/common/static_config.py b/src/common/static_config.py index c87237d1..5c27bc14 100644 --- a/src/common/static_config.py +++ b/src/common/static_config.py @@ -1,11 +1,19 @@ PUBLIC_INITIAL_PEERS = [ "/dns4/bootstrap-lattica.gradient.network/udp/18080/quic-v1/p2p/12D3KooWJHXvu8TWkFn6hmSwaxdCLy4ZzFwr4u5mvF9Fe2rMmFXb", "/dns4/bootstrap-lattica.gradient.network/tcp/18080/p2p/12D3KooWJHXvu8TWkFn6hmSwaxdCLy4ZzFwr4u5mvF9Fe2rMmFXb", + "/dns4/bootstrap-lattica-us.gradient.network/udp/18080/quic-v1/p2p/12D3KooWFD8NoyHfmVxLVCocvXJBjwgE9RZ2bgm2p5WAWQax4FoQ", + "/dns4/bootstrap-lattica-us.gradient.network/tcp/18080/p2p/12D3KooWFD8NoyHfmVxLVCocvXJBjwgE9RZ2bgm2p5WAWQax4FoQ", + "/dns4/bootstrap-lattica-eu.gradient.network/udp/18080/quic-v1/p2p/12D3KooWCNuEF4ro95VA4Lgq4NvjdWfJFoTcvWsBA7Z6VkBByPtN", + "/dns4/bootstrap-lattica-eu.gradient.network/tcp/18080/p2p/12D3KooWCNuEF4ro95VA4Lgq4NvjdWfJFoTcvWsBA7Z6VkBByPtN", ] PUBLIC_RELAY_SERVERS = [ "/dns4/relay-lattica.gradient.network/udp/18080/quic-v1/p2p/12D3KooWDaqDAsFupYvffBDxjHHuWmEAJE4sMDCXiuZiB8aG8rjf", "/dns4/relay-lattica.gradient.network/tcp/18080/p2p/12D3KooWDaqDAsFupYvffBDxjHHuWmEAJE4sMDCXiuZiB8aG8rjf", + "/dns4/relay-lattica-us.gradient.network/udp/18080/quic-v1/p2p/12D3KooWHMXi6SCfaQzLcFt6Th545EgRt4JNzxqmDeLs1PgGm3LU", + "/dns4/relay-lattica-us.gradient.network/tcp/18080/p2p/12D3KooWHMXi6SCfaQzLcFt6Th545EgRt4JNzxqmDeLs1PgGm3LU", + "/dns4/relay-lattica-eu.gradient.network/udp/18080/quic-v1/p2p/12D3KooWRAuR7rMNA7Yd4S1vgKS6akiJfQoRNNexTtzWxYPiWfG5", + "/dns4/relay-lattica-eu.gradient.network/tcp/18080/p2p/12D3KooWRAuR7rMNA7Yd4S1vgKS6akiJfQoRNNexTtzWxYPiWfG5", ] diff --git a/src/parallax/cli.py b/src/parallax/cli.py index b039855a..58a3f8b3 100644 --- a/src/parallax/cli.py +++ b/src/parallax/cli.py @@ -14,11 +14,27 @@ import sys from common.file_util import get_project_root -from common.static_config import get_relay_params from parallax_utils.logging_config import get_logger logger = get_logger("parallax.cli") +PUBLIC_INITIAL_PEERS = [ + "/dns4/bootstrap-lattica.gradient.network/udp/18080/quic-v1/p2p/12D3KooWJHXvu8TWkFn6hmSwaxdCLy4ZzFwr4u5mvF9Fe2rMmFXb", + "/dns4/bootstrap-lattica.gradient.network/tcp/18080/p2p/12D3KooWJHXvu8TWkFn6hmSwaxdCLy4ZzFwr4u5mvF9Fe2rMmFXb", + "/dns4/bootstrap-lattica-us.gradient.network/udp/18080/quic-v1/p2p/12D3KooWFD8NoyHfmVxLVCocvXJBjwgE9RZ2bgm2p5WAWQax4FoQ", + "/dns4/bootstrap-lattica-us.gradient.network/tcp/18080/p2p/12D3KooWFD8NoyHfmVxLVCocvXJBjwgE9RZ2bgm2p5WAWQax4FoQ", + "/dns4/bootstrap-lattica-eu.gradient.network/udp/18080/quic-v1/p2p/12D3KooWCNuEF4ro95VA4Lgq4NvjdWfJFoTcvWsBA7Z6VkBByPtN", + "/dns4/bootstrap-lattica-eu.gradient.network/tcp/18080/p2p/12D3KooWCNuEF4ro95VA4Lgq4NvjdWfJFoTcvWsBA7Z6VkBByPtN", +] + +PUBLIC_RELAY_SERVERS = [ + "/dns4/relay-lattica.gradient.network/udp/18080/quic-v1/p2p/12D3KooWDaqDAsFupYvffBDxjHHuWmEAJE4sMDCXiuZiB8aG8rjf", + "/dns4/relay-lattica.gradient.network/tcp/18080/p2p/12D3KooWDaqDAsFupYvffBDxjHHuWmEAJE4sMDCXiuZiB8aG8rjf", + "/dns4/relay-lattica-us.gradient.network/udp/18080/quic-v1/p2p/12D3KooWHMXi6SCfaQzLcFt6Th545EgRt4JNzxqmDeLs1PgGm3LU", + "/dns4/relay-lattica-us.gradient.network/tcp/18080/p2p/12D3KooWHMXi6SCfaQzLcFt6Th545EgRt4JNzxqmDeLs1PgGm3LU", + "/dns4/relay-lattica-eu.gradient.network/udp/18080/quic-v1/p2p/12D3KooWRAuR7rMNA7Yd4S1vgKS6akiJfQoRNNexTtzWxYPiWfG5", + "/dns4/relay-lattica-eu.gradient.network/tcp/18080/p2p/12D3KooWRAuR7rMNA7Yd4S1vgKS6akiJfQoRNNexTtzWxYPiWfG5", +] def check_python_version(): """Check if Python version is 3.11 or higher.""" @@ -140,6 +156,13 @@ def _force_kill_handler(signum, frame): logger.info("Subprocess not found, skipping shutdown...") sys.exit(0) +def _get_relay_params(): + return [ + "--relay-servers", + *PUBLIC_RELAY_SERVERS, + "--initial-peers", + *PUBLIC_INITIAL_PEERS, + ] def run_command(args, passthrough_args: list[str] | None = None): """Run the scheduler (equivalent to scripts/start.sh).""" @@ -164,7 +187,7 @@ def run_command(args, passthrough_args: list[str] | None = None): if args.init_nodes_num: cmd.extend(["--init-nodes-num", str(args.init_nodes_num)]) if args.use_relay: - cmd.extend(get_relay_params()) + cmd.extend(_get_relay_params()) # Append any passthrough args (unrecognized by this CLI) directly to the command if passthrough_args: @@ -208,7 +231,7 @@ def join_command(args, passthrough_args: list[str] | None = None): args.scheduler_addr != "auto" and not str(args.scheduler_addr).startswith("/") ): logger.info("Using public relay servers") - cmd.extend(get_relay_params()) + cmd.extend(_get_relay_params()) # Append any passthrough args (unrecognized by this CLI) directly to the command if passthrough_args: From 106116ada7c0f2680f47b8e2f8a88d400f671d5f Mon Sep 17 00:00:00 2001 From: gufengc Date: Thu, 23 Oct 2025 17:55:14 +0800 Subject: [PATCH 2/3] update --- src/parallax/cli.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/parallax/cli.py b/src/parallax/cli.py index 58a3f8b3..c47ad534 100644 --- a/src/parallax/cli.py +++ b/src/parallax/cli.py @@ -36,6 +36,7 @@ "/dns4/relay-lattica-eu.gradient.network/tcp/18080/p2p/12D3KooWRAuR7rMNA7Yd4S1vgKS6akiJfQoRNNexTtzWxYPiWfG5", ] + def check_python_version(): """Check if Python version is 3.11 or higher.""" if sys.version_info < (3, 11) or sys.version_info >= (3, 14): @@ -156,6 +157,7 @@ def _force_kill_handler(signum, frame): logger.info("Subprocess not found, skipping shutdown...") sys.exit(0) + def _get_relay_params(): return [ "--relay-servers", @@ -164,6 +166,7 @@ def _get_relay_params(): *PUBLIC_INITIAL_PEERS, ] + def run_command(args, passthrough_args: list[str] | None = None): """Run the scheduler (equivalent to scripts/start.sh).""" check_python_version() From 3122d80e1992ac7c0ccaabfeda21b0065ac3f215 Mon Sep 17 00:00:00 2001 From: gufengc Date: Thu, 23 Oct 2025 17:56:34 +0800 Subject: [PATCH 3/3] update --- src/common/static_config.py | 26 -------------------------- 1 file changed, 26 deletions(-) delete mode 100644 src/common/static_config.py diff --git a/src/common/static_config.py b/src/common/static_config.py deleted file mode 100644 index 5c27bc14..00000000 --- a/src/common/static_config.py +++ /dev/null @@ -1,26 +0,0 @@ -PUBLIC_INITIAL_PEERS = [ - "/dns4/bootstrap-lattica.gradient.network/udp/18080/quic-v1/p2p/12D3KooWJHXvu8TWkFn6hmSwaxdCLy4ZzFwr4u5mvF9Fe2rMmFXb", - "/dns4/bootstrap-lattica.gradient.network/tcp/18080/p2p/12D3KooWJHXvu8TWkFn6hmSwaxdCLy4ZzFwr4u5mvF9Fe2rMmFXb", - "/dns4/bootstrap-lattica-us.gradient.network/udp/18080/quic-v1/p2p/12D3KooWFD8NoyHfmVxLVCocvXJBjwgE9RZ2bgm2p5WAWQax4FoQ", - "/dns4/bootstrap-lattica-us.gradient.network/tcp/18080/p2p/12D3KooWFD8NoyHfmVxLVCocvXJBjwgE9RZ2bgm2p5WAWQax4FoQ", - "/dns4/bootstrap-lattica-eu.gradient.network/udp/18080/quic-v1/p2p/12D3KooWCNuEF4ro95VA4Lgq4NvjdWfJFoTcvWsBA7Z6VkBByPtN", - "/dns4/bootstrap-lattica-eu.gradient.network/tcp/18080/p2p/12D3KooWCNuEF4ro95VA4Lgq4NvjdWfJFoTcvWsBA7Z6VkBByPtN", -] - -PUBLIC_RELAY_SERVERS = [ - "/dns4/relay-lattica.gradient.network/udp/18080/quic-v1/p2p/12D3KooWDaqDAsFupYvffBDxjHHuWmEAJE4sMDCXiuZiB8aG8rjf", - "/dns4/relay-lattica.gradient.network/tcp/18080/p2p/12D3KooWDaqDAsFupYvffBDxjHHuWmEAJE4sMDCXiuZiB8aG8rjf", - "/dns4/relay-lattica-us.gradient.network/udp/18080/quic-v1/p2p/12D3KooWHMXi6SCfaQzLcFt6Th545EgRt4JNzxqmDeLs1PgGm3LU", - "/dns4/relay-lattica-us.gradient.network/tcp/18080/p2p/12D3KooWHMXi6SCfaQzLcFt6Th545EgRt4JNzxqmDeLs1PgGm3LU", - "/dns4/relay-lattica-eu.gradient.network/udp/18080/quic-v1/p2p/12D3KooWRAuR7rMNA7Yd4S1vgKS6akiJfQoRNNexTtzWxYPiWfG5", - "/dns4/relay-lattica-eu.gradient.network/tcp/18080/p2p/12D3KooWRAuR7rMNA7Yd4S1vgKS6akiJfQoRNNexTtzWxYPiWfG5", -] - - -def get_relay_params(): - return [ - "--relay-servers", - *PUBLIC_RELAY_SERVERS, - "--initial-peers", - *PUBLIC_INITIAL_PEERS, - ]