def METHOD_NAME(self):
    if airflow_version >= "2.6":
        scheduler_job = self._run_new_scheduler_job()
    else:
        scheduler_job = self._run_old_scheduler_job()
    try:
        scheduler_job.kill()
    except Exception as exc:
        logger.debug(traceback.format_exc())
        logger.info(f"Rescan Complete: Killed Job: {exc}")