code: def prepare_worker(self):
          
          worker_options = self.prepare_worker_options()
          self.worker = self.options.worker_class(**worker_options)
          if self.update_title:
              self.worker._add_update_status_callback(self.update_proc_title)
              self.update_proc_title()
  
          if not self.worker.logger.handlers:
              handler = logging.StreamHandler()
              handler.setFormatter(logging.Formatter(
                                          ' '.join(['[%(process)d]',
                                                    # '%(asctime)s,%(msecs).03d',
                                                    '%(asctime)s',
                                                    '(%(name)s)',
                                                    '%(levelname)-8s',
                                                    '%(message)s',
                                                   ])
                                          # , '%y.%m.%d:%H.%M.%S'
                                      ))
              self.worker.logger.addHandler(handler)
  
          if self.options.dry_run:
              self.worker.end_forced = True
docs: Prepare the worker, ready to be launched: prepare options, create a
          log handler if none, and manage dry_run options