def METHOD_NAME(self, task):
    collection = get_dataset_collection_id(task.job.dataset.name)
    if collection is not None:
        collection = Collection.by_id(collection, deleted=True)
    log.info(f"Task [{task.job.dataset}]: {task.stage.stage} (started)")
    handler = OPERATIONS[task.stage.stage]
    handler(collection, task)
    log.info(f"Task [{task.job.dataset}]: {task.stage.stage} (done)")