"""Logic for dms_delivery_spec.""" from src.connectors import logging from src.constants import fields from src.constants import maxwell from src.models import jobs def process_dms_delivery_spec(records): """Process dms_delivery_spec changes. 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]: logging.logger.debug( 'dms_delivery_spec was updated for ' f'DMS: {data[fields.DMS_MASTER_MASTER_ID]}, ' f'order type: {data[fields.ORDER_TYPE]}') jobs.set_store_spec( data[fields.ORDER_TYPE], data[fields.DMS_MASTER_MASTER_ID], data[fields.ENCODING], data[fields.DELIVERY])