"""Example dag helpers."""

from lib import constants
from lib.utils import event


def get_event_from_params(dag_run, **kwargs):
    """Get event from params passed to task callbacks."""
    abacus_event = event.get_abacus_event(dag_run, **kwargs)
    event.validate_event_for_handler(
        abacus_event,
        target_type=constants.DAG_CALC_TARGET_TYPE,
        event_name=constants.DAG_CALC_EVENT_NAME
    )
    return abacus_event