'Store the result of an executed group.'

@retry
def _save_group(self, group_id, result):

    session = self.ResultSession()
    with session_cleanup(session):
        group = TaskSet(group_id, result)
        session.add(group)
        session.flush()
        session.commit()
        return result
