def METHOD_NAME(self, tmp=None, task_vars=None):
    super().METHOD_NAME(tmp, task_vars)
    self._check_args()
    msg = ""
    if "msg" in self._task.args:
        msg = str(self._task.args["msg"])
    objects = []
    context_obj = get_context_object(task_vars=task_vars)
    if "objects" in self._task.args:
        self._process_objects(objects=objects, context_obj=context_obj, task_vars=task_vars)
    else:
        objects.append(context_obj)
    for obj in objects:
        if self._task.args["operation"] == "up":
            update_object_flag(obj=obj, msg=msg)
        elif self._task.args["operation"] == "down":
            remove_flag(obj=obj, msg=msg)
    return {"failed": False, "changed": True}