"""Complete run task method."""

from lib.utils import ows
from tasks.accounting_run_calculate import helpers


def status_complete(dag_run, **kwargs):
    """Mark run as complete."""
    event = helpers.get_event_from_params(dag_run, **kwargs)
    options = {
        'accounting_run_status': 'Complete',
    }
    ows.update_accounting_run(event.target_id, **options)