def METHOD_NAME(self, assigned):
    """
    A coroutine or function the user can implement to provide load of
    custom consumer state or cache warmup on completion of a successful
    partition re-assignment.
    This method will be called *after* partition re-assignment completes
    and *before* the consumer starts fetching data again.
    It is guaranteed that all the processes in a consumer group will
    execute their :meth:`on_partitions_revoked` callback before any instance
    executes its :meth:`on_partitions_assigned` callback.
    Arguments:
        assigned (list(TopicPartition)): the partitions assigned to the
            consumer (may include partitions that were previously assigned)
    """
    pass