Only_run_latest

from datetime import datetime
from airflow.models import DAG
from airflow.operators import BashOperator, ShortCircuitOperator
import logging


def skip_to_current_job(ds, **kwargs):
    now = datetime.now()
    left_window = kwargs['dag'].following_schedule(kwargs['execution_date'])
    right_window = kwargs['dag'].following_schedule(left_window)
    logging.info(('Left Window {}, Now {}, Right Window {}').format(left_window,now,right_window))
    if not now <= right_window:
        logging.info('Not latest execution, skipping downstream.')
        return False
    return True