code: func (b *Backend) GroupCompleted(groupUUID string, groupTaskCount int) (bool, error) {
  	conn, channel, err := b.Open(b.GetConfig().Broker, b.GetConfig().TLSConfig)
  	if err != nil {
  		return false, err
  	}
  	defer b.Close(channel, conn)
  
  	queueState, err := b.InspectQueue(channel, groupUUID)
  	if err != nil {
  		return false, nil
  	}
  
  	return queueState.Messages == groupTaskCount, nil
  }
docs: // GroupCompleted returns true if all tasks in a group finished
  // NOTE: Given AMQP limitation this will only return true if all finished
  // tasks were successful as we do not keep track of completed failed tasks