Remove dependency on Fairring

Summary: We intend to remove/archive Fairring, since it hasn't been developed in 2 years. For that we need to first clean up the projects that depend on it. Reviewed By: bottler Differential Revision: D60222759 fbshipit-source-id: 182c9496644e0408a582f916aae7f5f3391b0de1
facebookresearch · Jul 25, 2024 · c9e2255 · c9e2255
1 parent fceef73
commit c9e2255
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 14 deletions.
diff --git a/et_replay/comm/pytorch_backend_utils.py b/et_replay/comm/pytorch_backend_utils.py
@@ -15,7 +15,7 @@
 logger = logging.getLogger(__name__)
 
 supportedDevices = ["cpu", "cuda", "rocm", "tpu"]
-supportedC10dBackends = ["nccl", "gloo", "mpi", "ucc", "xla", "fairring"]
+supportedC10dBackends = ["nccl", "gloo", "mpi", "ucc", "xla"]
 supportedCollectives = [
     "reduce",
     "all_reduce",

diff --git a/et_replay/comm/pytorch_dist_backend.py b/et_replay/comm/pytorch_dist_backend.py
@@ -1008,12 +1008,6 @@ def __init__(self, bootstrap_info, commsParams):
                     raise RuntimeError("Unable to import initialize_ucc_plugin")
                 else:
                     initialize_ucc_plugin(backend)
-        # Import Fairring
-        if backend == "fairring":
-            try:
-                import fairring  # noqa
-            except ImportError:
-                raise RuntimeError("Unable to import Fairring")
 
     def get_new_pg(self, group_ranks, backend):
         if self.use_ext_dist:

diff --git a/train/comms/pt/pytorch_backend_utils.py b/train/comms/pt/pytorch_backend_utils.py
@@ -16,7 +16,7 @@
 logger = logging.getLogger(__name__)
 
 supportedDevices = ["cpu", "cuda", "rocm", "tpu"]
-supportedC10dBackends = ["nccl", "gloo", "mpi", "ucc", "xla", "fairring"]
+supportedC10dBackends = ["nccl", "gloo", "mpi", "ucc", "xla"]
 supportedCollectives = [
     "reduce",
     "all_reduce",

diff --git a/train/comms/pt/pytorch_dist_backend.py b/train/comms/pt/pytorch_dist_backend.py
@@ -1010,12 +1010,6 @@ def __init__(self, bootstrap_info, commsParams):
                     raise RuntimeError("Unable to import initialize_ucc_plugin")
                 else:
                     initialize_ucc_plugin(backend)
-        # Import Fairring
-        if backend == "fairring":
-            try:
-                import fairring  # noqa
-            except ImportError:
-                raise RuntimeError("Unable to import Fairring")
 
     def get_new_pg(self, group_ranks, backend):
         if self.use_ext_dist: