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?