shutdown¶

paddle.distributed.rpc. shutdown ( ) [source]

Perform a shutdown of the RPC agent, stop the worker and destroy the agent. This will block until all local and remote RPC processes reach this method and wait for all outstanding work to complete.

Returns

None.

Examples

>>> 
>>> import paddle.distributed.rpc as rpc

>>> rpc.init_rpc("worker0", rank=0, world_size=1,
...             master_endpoint="127.0.0.1:8004")

>>> rpc.shutdown()