Calling service method over rpc


Not sure how to phrase this.

If I have a service method that needs to call another method in the same service, I can self.thing(args) and it executes. But how would I go about calling thing over RPC?

My use-case is I have a IO bound process that I fan out to multiple hosts using a ThreadPoolExecutor. If I self.thing then they all run on the same host.

What I’ve been doing is creating an RpcProxy object for the service, on itself:

myservice = RpcProxy('myservice')

then calling it as self.myservice.thing(args) and it works. But this feels wrong. Is there something already baked into the methods?

Many thanks,