diff --git a/nemo_run/core/execution/skypilot.py b/nemo_run/core/execution/skypilot.py index 0fe2fa82..3acb1f7c 100644 --- a/nemo_run/core/execution/skypilot.py +++ b/nemo_run/core/execution/skypilot.py @@ -27,7 +27,6 @@ Executor, ExecutorMacros, ) -from nemo_run.core.execution.launcher import FaultTolerance, Torchrun from nemo_run.core.packaging.base import Packager from nemo_run.core.packaging.git import GitArchivePackager @@ -330,18 +329,6 @@ def macro_values(self) -> Optional[ExecutorMacros]: het_group_host_var=self.HET_GROUP_HOST_VAR, ) - def _setup_launcher(self): - super()._setup_launcher() - launcher = self.launcher - # Dynamic rendezvous has an error in Skypilot Kubernetes currently - if ( - launcher - and isinstance(launcher, (Torchrun, FaultTolerance)) - and self.cloud == "kubernetes" - ): - launcher.rdzv_backend = "static" - launcher.rdzv_port = 49500 - def to_task( self, name: str,