

def _make_routing_call(self, call, timeout, *op_args, **op_kwargs):
    if (not self._routing_call):
        return RPCResponseEndpointUnit._make_routing_call(self, call, timeout, *op_kwargs, **op_kwargs)
    ctx = self._process.get_context()
    ar = self._routing_call(call, ctx, *op_args, **op_kwargs)
    res = ar.get()
    if hasattr(self._process, '_proc_state'):
        if self._process._proc_state_changed:
            log.debug('Process %s state changed. State=%s', self._process.id, self._process._proc_state)
            self._process._flush_state()
    return res

dataset/ETHPy150Open ooici/pyon/pyon/ion/endpoint.py ProcessRPCResponseEndpointUnit._make_routing_call/VarMisuse@42/59 `op_args`->`op_kwargs`