code: def put_task(self, func, args, response):
          
  
          self._rpc_queue.put_nowait((func, args, response))
docs: 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.