code: def execute_command(self, *args, **kwargs):
          
          try:
              return self.get_connection().execute_command(*args, **kwargs)
          except ConnectionError as e:
              logger.warn('trying to reconnect')
              self.connect()
              logger.warn('connected')
              raise
docs: Execute a command on the connected server.