def test_rpc_communicator_close():
# Ensures it is possible to open a new RPC Communicators
# after closing one on the same worker_id
first_comm = RpcCommunicator()
first_comm.close()
second_comm = RpcCommunicator()