def on_assignment(cls, assignment):
        """Callback that runs on each assignment. Updates assignor's state.

        Arguments:
          assignment: MemberAssignment
        """
        log.debug("On assignment: assignment={}".format(assignment))
        cls.member_assignment = assignment.partitions()
Callback that runs on each assignment. Updates assignor's state.

        Arguments:
          assignment: MemberAssignment
        
kafka/coordinator/assignors/sticky/sticky_assignor.py