shutdown

paddle.distributed.rpc. shutdown ( ) → None [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. Warning: All RPC API should only be used internally within a secure network environment and must not be accessible via the public internet.

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()