code: def execute(self, command, *args, **kw):
          
          conn, address = self.get_connection(command, args)
          if conn is not None:
              fut = conn.execute(command, *args, **kw)
              return self._check_result(fut, command, args, kw)
          else:
              coro = self._wait_execute(address, command, args, kw)
              return self._check_result(coro, command, args, kw)
docs: Executes redis command in a free connection and returns
          future waiting for result.
  
          Picks connection from free pool and send command through
          that connection.
          If no connection is found, returns coroutine waiting for
          free connection to execute command.