Re: [DISCUSSION] Specify tasks to skip when triggering DAG

[Daniel Standish]

That skip func had a typo (conf where it should have been context)...

this is more likely to work:

def skip_if_specified(context):
    if not context:
        return
    dr = context.get('dag_run')
    ti = context.get('task_instance')
    if not (dr and ti):
        return
    conf = dr.conf
    if not conf:
        return
    skip_list = conf.get('skip_list', [])
    if ti.task_id in skip_list:
        raise AirflowSkipException()

Apologies for the spam.