Hi,
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,
Geoff