code: def validate(self):
          
          for process_name, q in self.reprocess_uows.items():
              if not q:
                  continue
  
              invalid_entries = list()
              for entry in q.queue:
                  assert isinstance(entry, PriorityEntry)
                  uow = self.uow_dao.get_one(entry.entry.db_id)
                  if uow.is_canceled:
                      invalid_entries.append(entry)
  
                  thread_handler = self.managed_handlers[uow.process_name]
                  assert isinstance(thread_handler, ManagedThreadHandler)
                  if not thread_handler.process_entry.is_on:
                      invalid_entries.append(entry)
  
              for entry in invalid_entries:
                  q.queue.remove(entry)
  
          self.logger.info('reprocessing queue validated')
docs: method iterates over the reprocessing queue and synchronizes state of every UOW with the DB
              should it change via the MX to STATE_CANCELED - remove the UOW from the queue