code: def _execute_command(self, key, *args):
          
          client = self.redis_clients[key.redis_shard_hash() % len(
              self.redis_clients)]
          return client.execute_command(*args)
docs: Execute a Redis command on the appropriate Redis shard based on key.
  
          Args:
              key: The object ID or the task ID that the query is about.
              args: The command to run.
  
          Returns:
              The value returned by the Redis command.