[ADAG] Refactor nccl to communicator channel.

doc/source/conf.py

@@ -339,9 +339,11 @@ def render_svg_logo(path):
 
 html_sidebars = {
     "**": [
-        "main-sidebar-readthedocs"
-        if os.getenv("READTHEDOCS") == "True"
-        else "main-sidebar"
+        (
+            "main-sidebar-readthedocs"
+            if os.getenv("READTHEDOCS") == "True"
+            else "main-sidebar"
+        )
     ],
     "ray-overview/examples": [],
 }

python/ray/_private/accelerators/npu.py

@@ -94,6 +94,6 @@ def set_current_process_visible_accelerator_ids(
         if os.environ.get(NOSET_ASCEND_RT_VISIBLE_DEVICES_ENV_VAR):
             return
 
-        os.environ[
-            NPUAcceleratorManager.get_visible_accelerator_ids_env_var()
-        ] = ",".join([str(i) for i in visible_npu_devices])
+        os.environ[NPUAcceleratorManager.get_visible_accelerator_ids_env_var()] = (
+            ",".join([str(i) for i in visible_npu_devices])
+        )

python/ray/_private/utils.py

@@ -387,9 +387,9 @@ def resources_from_ray_options(options_dict: Dict[str, Any]) -> Dict[str, Any]:
     if object_store_memory is not None:
         resources["object_store_memory"] = object_store_memory
     if accelerator_type is not None:
-        resources[
-            f"{ray_constants.RESOURCE_CONSTRAINT_PREFIX}{accelerator_type}"
-        ] = 0.001
+        resources[f"{ray_constants.RESOURCE_CONSTRAINT_PREFIX}{accelerator_type}"] = (
+            0.001
+        )
 
     return resources
 
@@ -1146,9 +1146,11 @@ def new_func(*args, **kwargs):
                     + (
                         f"in version {removal_release}."
                         if removal_release is not None
-                        else f"after {removal_date}"
-                        if removal_date is not None
-                        else "in a future version"
+                        else (
+                            f"after {removal_date}"
+                            if removal_date is not None
+                            else "in a future version"
+                        )
                     )
                     + (f" {instructions}" if instructions is not None else "")
                 )