def METHOD_NAME(self, loop):
    global_instance = self.instance_cache.get_instance(self.profile_id, None)
    if global_instance != self.instance_id:
        logger.info(
            f"Execution DISCARDED. Execution passed from worker instance {self.instance_id} to instance {global_instance}")
        return
    try:
        # should the execution be postponed. If there was no second call then postpone is None.
        if self.global_postpone_flag.get(self.profile_id) is False:
            logger.info(f"Profile {self.profile_id} destination sync RUNS from instance {self.instance_id}.")
            # it is not postponed - run it now
            self._run_scheduled()
            # clean cache
            self.global_postpone_flag.reset(self.profile_id)
            self.global_schedule_flag.reset(self.profile_id)
            self.instance_cache.reset(self.profile_id)
        else:
            # postpone call. Postpone flag is true
            self._schedule_for_later(loop)
            logger.info(
                f"Execution on worker instance {self.instance_id} POSTPONED for {self.wait}s for profile {self.profile_id}")
            # delete postpone flag. It can be set again if there is another call.
            self.global_postpone_flag.reset(self.profile_id)
    except Exception as e:
        logger.error(str(e))