"""Notify that payoneer payments payout task succeeded."""

from lib import constants
from lib.utils import ows
from tasks.payoneer_payments_payout import helpers


def notify_success_task(dag_run, **kwargs):
    """Update specified action state's action_status to 'complete'."""
    event = helpers.get_event_from_params(dag_run, **kwargs)
    action_name = kwargs.get('action_name')
    abacus_state_id = ows.get_abacus_state_id(
        constants.DAG_PAYONEER_PAYMENTS_PAYOUT_TARGET_TYPE,
        event.target_id,
        action_name
    )
    if abacus_state_id:
        ows.update_abacus_state(
            abacus_state_id,
            body=dict(
                action_status=constants.ABACUS_STATE_STATUSES.COMPLETE
            )
        )