def setup_csv_record_validation(self, file, file_type):
    self.session.query(Job).delete(synchronize_session='fetch')
    self.val_job = insert_job(self.session, FILE_TYPE_DICT[file_type], JOB_STATUS_DICT['ready'], JOB_TYPE_DICT['csv_record_validation'], self.submission_id, filename=file)
def setup_csv_record_validation(self, file, file_type):
    self.session.query(Job).delete(synchronize_session='fetch')
    self.val_job = insert_job(self.session, FILE_TYPE_DICT[file_type], JOB_STATUS_DICT['ready'], JOB_TYPE_DICT['csv_record_validation'], self.submission_id, filename=file)