def put_task(self, func, args, response):
        """Place a task onto the RPC queue.

        This temporary functionality will go away but it lets you run a
        task synchronously with RPC dispatch by placing it onto the
        RCP queue.

        Args:
            func (callable): The function to execute
            args (iterable): The function arguments
            response (GenericResponse): The response object to signal the
                result on.
        """

        self._rpc_queue.put_nowait((func, args, response))
def put_task ( self , func , args , response ) : self . _rpc_queue . put_nowait ( ( func , args , response ) )
Place a task onto the RPC queue.

        This temporary functionality will go away but it lets you run a
        task synchronously with RPC dispatch by placing it onto the
        RCP queue.

        Args:
            func (callable): The function to execute
            args (iterable): The function arguments
            response (GenericResponse): The response object to signal the
                result on.