From a4be7e63d001f3308b59ed9fdfbdc8bfd8b63966 Mon Sep 17 00:00:00 2001 From: Hossein Kavianihamedani Date: Mon, 17 Nov 2025 10:22:29 -0800 Subject: [PATCH 1/2] Fix launcher issues --- src/forge/controller/launcher.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/forge/controller/launcher.py b/src/forge/controller/launcher.py index 43c8e65c1..db44a1d8b 100644 --- a/src/forge/controller/launcher.py +++ b/src/forge/controller/launcher.py @@ -25,6 +25,7 @@ from monarch.actor import Actor, endpoint, ProcMesh from monarch.tools import commands from monarch.tools.commands import create, info +from monarch.tools.components import hyperactor from monarch.tools.config import Config, Workspace _MAST_AVAILABLE = False @@ -126,7 +127,8 @@ async def initialize(self) -> None: # HostMesh currently requires explicit configuration # of the underlying transport from client to mesh. # This can be removed in the future once this has been removed. - configure(default_transport=ChannelTransport.Tcp) + # Changed TCP this to TcpWithHostname for the slurm launcher + configure(default_transport=ChannelTransport.TcpWithHostname) async def get_allocator(self, name: str, num_hosts: int) -> tuple[Any, Any, str]: appdef = hyperactor.host_mesh( From 37ab4c6123d838ab83b67d613622cdfbf051dbaf Mon Sep 17 00:00:00 2001 From: Allen Wang <9057208+allenwang28@users.noreply.github.com> Date: Tue, 18 Nov 2025 10:36:53 -0500 Subject: [PATCH 2/2] Update src/forge/controller/launcher.py Co-authored-by: Felipe Mello --- src/forge/controller/launcher.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/forge/controller/launcher.py b/src/forge/controller/launcher.py index db44a1d8b..c40982634 100644 --- a/src/forge/controller/launcher.py +++ b/src/forge/controller/launcher.py @@ -127,7 +127,6 @@ async def initialize(self) -> None: # HostMesh currently requires explicit configuration # of the underlying transport from client to mesh. # This can be removed in the future once this has been removed. - # Changed TCP this to TcpWithHostname for the slurm launcher configure(default_transport=ChannelTransport.TcpWithHostname) async def get_allocator(self, name: str, num_hosts: int) -> tuple[Any, Any, str]: