airflow/utils/cli_action_loggers.py
def on_pre_execution(**kwargs):
    """
    Calls callbacks before execution.
    Note that any exception from callback will be logged but won't be propagated.
    :param kwargs:
    :return: None
    """
    logging.debug("Calling callbacks: %s", __pre_exec_callbacks)
    for cb in __pre_exec_callbacks:
        try:
            cb(**kwargs)
        except Exception:
            logging.exception('Failed on pre-execution callback using %s', cb)
def on_pre_execution(**kwargs):
    """
    Calls callbacks before execution.
    Note that any exception from callback will be logged but won't be propagated.
    :param kwargs:
    :return: None
    """
    logging.debug("Calling callbacks: %s", __pre_exec_callbacks)
    for cb in __pre_exec_callbacks:
        try:
            cb(**kwargs)
        except Exception:
            logging.exception('Failed on pre-execution callback using %s', cb)
def on_pre_execution ( * * kwargs ) : logging . debug ( "Calling callbacks: %s" , __pre_exec_callbacks ) for cb in __pre_exec_callbacks : try : cb ( * * kwargs ) except Exception : logging . exception ( 'Failed on pre-execution callback using %s' , cb )
Calls callbacks before execution.
    Note that any exception from callback will be logged but won't be propagated.
    :param kwargs:
    :return: None
Calls callbacks before execution . Note that any exception from callback will be logged but won t be propagated . : param kwargs : : return : None