zeronimo/core.py
def dispatch_reply(self, reply, value):
        """Dispatches the reply to the proper queue."""
        method = reply.method
        call_id = reply.call_id
        task_id = reply.task_id
        if method & ACK:
            try:
                result_queue = self.result_queues[call_id]
            except KeyError:
                raise KeyError('already established or unprepared call')
            if method == ACCEPT:
                worker_info = value
                result = RemoteResult(self, call_id, task_id, worker_info)
                self.results[call_id][task_id] = result
                result_queue.put_nowait(result)
            elif method == REJECT:
                result_queue.put_nowait(None)
        else:
            result = self.results[call_id][task_id]
            result.set_reply(reply.method, value)
def dispatch_reply(self, reply, value):
        """Dispatches the reply to the proper queue."""
        method = reply.method
        call_id = reply.call_id
        task_id = reply.task_id
        if method & ACK:
            try:
                result_queue = self.result_queues[call_id]
            except KeyError:
                raise KeyError('already established or unprepared call')
            if method == ACCEPT:
                worker_info = value
                result = RemoteResult(self, call_id, task_id, worker_info)
                self.results[call_id][task_id] = result
                result_queue.put_nowait(result)
            elif method == REJECT:
                result_queue.put_nowait(None)
        else:
            result = self.results[call_id][task_id]
            result.set_reply(reply.method, value)
def dispatch_reply ( self , reply , value ) : method = reply . method call_id = reply . call_id task_id = reply . task_id if method & ACK : try : result_queue = self . result_queues [ call_id ] except KeyError : raise KeyError ( 'already established or unprepared call' ) if method == ACCEPT : worker_info = value result = RemoteResult ( self , call_id , task_id , worker_info ) self . results [ call_id ] [ task_id ] = result result_queue . put_nowait ( result ) elif method == REJECT : result_queue . put_nowait ( None ) else : result = self . results [ call_id ] [ task_id ] result . set_reply ( reply . method , value )
Dispatches the reply to the proper queue.
Dispatches the reply to the proper queue .