Home
last modified time | relevance | path

Searched refs:rpc_async_method (Results 1 – 1 of 1) sorted by relevance

/aosp_15_r20/external/pytorch/torch/testing/_internal/distributed/rpc/
H A Ddist_optimizer_test.py77 def rpc_async_method(method, obj_rref, *args, **kwargs): function
118 output1 = rpc_async_method(MyModule.forward, remote_module1, t2)
119 output2 = rpc_async_method(MyModule.forward, remote_module2, output1.wait())
186 output1 = rpc_async_method(MyModule.forward, remote_module1, t2)
187 output2 = rpc_async_method(MyModule.forward, remote_module2, output1.wait())
193 new_w1 = rpc_async_method(MyModule.get_w, remote_module1).wait()
194 new_w2 = rpc_async_method(MyModule.get_w, remote_module2).wait()