"""Logic for orders (encoding_queue)."""

from src.configs import config
from src.constants import fields
from src.constants import maxwell
from src.models import jobs


def process_encoding_queue(records):
    """Process encoding_queue records.

    Args:
        records (dict): key (str) - operation,
        value - list of db records (dict)
    """
    if maxwell.TYPE_UPDATE in records:
        for data in records[maxwell.TYPE_UPDATE]:
            if (data[fields.ENCODING_ORDER_TYPE] in config.IGNORE_ORDER_TYPES):
                continue
            jobs.update_priority(
                data[fields.ENCODING_ORDER_ID], data[fields.PRIORITY])