"""Invoke payoneer payments payout lambda task method."""

from hooks.lambda_hook import OrchLambdaHook
from lib import config
from tasks.payoneer_payments_payout.helpers import get_event_from_params


def invoke_payoneer_payments_payout_lambda_task(dag_run, *arg, **kwargs):
    """Invoke lambda to send payments into Payoneer."""
    event = get_event_from_params(dag_run, **kwargs)

    hook = OrchLambdaHook(config.PAYONEER_PAYMENTS_PAYOUT_LAMBDA_NAME)

    response = hook.invoke_lambda(event.to_json())

    if not response.function_response.succeeded:
        raise Exception(response.error_message)