def METHOD_NAME(self, **options):
    confirm = input(
        """
        Please make sure you have read https://dimagi.github.io/commcare-cloud/changelog/0007-reorganize-pillows.html.
        Have you stopped all the to be merged pillows and added new pillows
        to this environment's app-processes.yml? y/N?
        """
    )
    if confirm != 'y':
        print("Checkpoint creation cancelled")
        return
    path = options['reorg_file_path']
    if path:
        with open(path, 'r') as f:
            reorg_mapping = json.loads(f.read())
    else:
        reorg_mapping = PILLOW_REORG_MAPPING
    try:
        checkpoint_id_mapping = pillow_to_checkpoint_id_mapping(reorg_mapping)
    except PillowNotFoundError as e:
        print(e)
        print("Please make sure that pillows are defined in current release")
        return
    new_checkpoints = KafkaCheckpoint.objects.filter(checkpoint_id__in=checkpoint_id_mapping)
    if options['cleanup']:
        new_checkpoints.delete()
    self._create_checkpoints(checkpoint_id_mapping, False)
    confirm = input(
        """
        Please check above reset offsets and make sure all merged checkpoints are relatively close.
        Do you want to proceed resetting per the above output? y/N?
        """
    )
    if confirm != 'y':
        print("Checkpoint creation cancelled")
        return
    else:
        self._create_checkpoints(checkpoint_id_mapping, True)