[CodeStyle][DocFormat][117] Use pycon marker in distributed runtime docs (#77980)

Author: ShigureNyako

python/paddle/distributed/communicator.py

@@ -52,7 +52,7 @@ def __init__(self, mode, kwargs=None, envs=None):
             None
 
         Examples:
-            .. code-block:: python
+            .. code-block:: pycon
 
                 >>> import paddle
 
@@ -135,7 +135,7 @@ def start(self):
             None
 
         Examples:
-            .. code-block:: python
+            .. code-block:: pycon
 
                 >>> import paddle
 
@@ -157,7 +157,7 @@ def stop(self):
             None
 
         Examples:
-            .. code-block:: python
+            .. code-block:: pycon
 
                 >>> import paddle
 
@@ -179,7 +179,7 @@ def is_running(self):
             bool
 
         Examples:
-            .. code-block:: python
+            .. code-block:: pycon
 
                 >>> import paddle
 

python/paddle/distributed/fleet/model.py

@@ -43,7 +43,7 @@ def distributed_model(model):
 
     Examples:
 
-        .. code-block:: python
+        .. code-block:: pycon
 
             >>> import paddle
             >>> import paddle.nn as nn
@@ -54,6 +54,7 @@ def distributed_model(model):
             ...         super().__init__()
             ...         self._linear1 = nn.Linear(10, 10)
             ...         self._linear2 = nn.Linear(10, 1)
+            ...
             ...     def forward(self, x):
             ...         return self._linear2(self._linear1(x))
 
@@ -64,7 +65,9 @@ def distributed_model(model):
             >>> layer = LinearNet()
             >>> loss_fn = nn.MSELoss()
             >>> adam = paddle.optimizer.Adam(
-            ...     learning_rate=0.001, parameters=layer.parameters())
+            ...     learning_rate=0.001,
+            ...     parameters=layer.parameters(),
+            ... )
 
             >>> # 3. get data_parallel model using fleet
             >>> adam = fleet.distributed_optimizer(adam)

python/paddle/distributed/parallel_with_gloo.py

@@ -54,38 +54,38 @@ def gloo_init_parallel_env(
         None
 
     Examples:
-        .. code-block:: python
+        .. code-block:: pycon
 
             >>> import paddle
             >>> import multiprocessing
             >>> from contextlib import closing
             >>> import socket
 
-            >>> port_set = set() # type: ignore
+            >>> port_set = set()  # type: ignore
 
             >>> def find_free_port():
             ...     def _free_port():
-            ...         with closing(socket.socket(socket.AF_INET,
-            ...             socket.SOCK_STREAM)) as s:
+            ...         with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as s:
             ...             s.bind(('', 0))
             ...             return s.getsockname()[1]
+            ...
             ...     while True:
             ...         port = _free_port()
             ...         if port not in port_set:
             ...             port_set.add(port)
             ...             return port
 
             >>> def test_gloo_init(id, rank_num, server_endpoint):
-            ...     paddle.distributed.gloo_init_parallel_env(
-            ...         id, rank_num, server_endpoint)
+            ...     paddle.distributed.gloo_init_parallel_env(id, rank_num, server_endpoint)
 
             >>> def test_gloo_init_with_multiprocess(num_of_ranks):
             ...     jobs = []
             ...     server_endpoint = "127.0.0.1:%s" % (find_free_port())
             ...     for id in range(num_of_ranks):
             ...         p = multiprocessing.Process(
             ...             target=test_gloo_init,
-            ...             args=(id, num_of_ranks, server_endpoint))
+            ...             args=(id, num_of_ranks, server_endpoint),
+            ...         )
             ...         jobs.append(p)
             ...         p.start()
             ...     for proc in jobs:
@@ -149,30 +149,29 @@ def gloo_barrier() -> None:
         None
 
     Examples:
-        .. code-block:: python
+        .. code-block:: pycon
 
             >>> import paddle
             >>> import multiprocessing
             >>> from contextlib import closing
             >>> import socket
 
-            >>> port_set = set() # type: ignore
+            >>> port_set = set()  # type: ignore
 
             >>> def find_free_port():
             ...     def _free_port():
-            ...         with closing(socket.socket(socket.AF_INET,
-            ...             socket.SOCK_STREAM)) as s:
+            ...         with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as s:
             ...             s.bind(('', 0))
             ...             return s.getsockname()[1]
+            ...
             ...     while True:
             ...         port = _free_port()
             ...         if port not in port_set:
             ...             port_set.add(port)
             ...             return port
 
             >>> def test_gloo_barrier(id, rank_num, server_endpoint):
-            ...     paddle.distributed.gloo_init_parallel_env(
-            ...         id, rank_num, server_endpoint)
+            ...     paddle.distributed.gloo_init_parallel_env(id, rank_num, server_endpoint)
             ...     paddle.distributed.gloo_barrier()
 
             >>> def test_gloo_barrier_with_multiprocess(num_of_ranks):
@@ -181,7 +180,8 @@ def gloo_barrier() -> None:
             ...     for id in range(num_of_ranks):
             ...         p = multiprocessing.Process(
             ...             target=test_gloo_barrier,
-            ...             args=(id, num_of_ranks, server_endpoint))
+            ...             args=(id, num_of_ranks, server_endpoint),
+            ...         )
             ...         jobs.append(p)
             ...         p.start()
             ...     for proc in jobs:
@@ -207,30 +207,29 @@ def gloo_release() -> None:
         None
 
     Examples:
-        .. code-block:: python
+        .. code-block:: pycon
 
             >>> import paddle
             >>> import multiprocessing
             >>> from contextlib import closing
             >>> import socket
 
-            >>> port_set = set() # type: ignore
+            >>> port_set = set()  # type: ignore
 
             >>> def find_free_port():
             ...     def _free_port():
-            ...         with closing(socket.socket(socket.AF_INET,
-            ...             socket.SOCK_STREAM)) as s:
+            ...         with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as s:
             ...             s.bind(('', 0))
             ...             return s.getsockname()[1]
+            ...
             ...     while True:
             ...         port = _free_port()
             ...         if port not in port_set:
             ...             port_set.add(port)
             ...             return port
 
             >>> def test_gloo_release(id, rank_num, server_endpoint):
-            ...     paddle.distributed.gloo_init_parallel_env(
-            ...         id, rank_num, server_endpoint)
+            ...     paddle.distributed.gloo_init_parallel_env(id, rank_num, server_endpoint)
             ...     paddle.distributed.gloo_barrier()
             ...     paddle.distributed.gloo_release()
 
@@ -240,7 +239,8 @@ def gloo_release() -> None:
             ...     for id in range(num_of_ranks):
             ...         p = multiprocessing.Process(
             ...             target=test_gloo_release,
-            ...             args=(id, num_of_ranks, server_endpoint))
+            ...             args=(id, num_of_ranks, server_endpoint),
+            ...         )
             ...         jobs.append(p)
             ...         p.start()
             ...     for proc in jobs: