- paddle.distributed.rpc. shutdown ( )
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.
import paddle.distributed.rpc as rpc rpc.init_rpc("worker0", rank=0, world_size=1, master_endpoint="127.0.0.1:8004") rpc.shutdown()