              self.add_queue(task)
              self.start_thread(task)
          logger.debug("Initialized DiskIO Threads")
  
      def add_queue(self, task):
          """ Add the queue to queue_manager and set queue attribute """
          logger.debug("Adding queue for task: '%s'", task)
          if task == "load":
              q_name = "convert_in"
          elif task == "save":
              q_name = "convert_out"
 
</s> remove             self.add_queue(task)
            self.start_thread(task)
 </s> add             self._add_queue(task)
            self._start_thread(task) </s> remove         setattr(self,
                "{}_queue".format(task),
                queue_manager.get_queue(q_name))
 </s> add         self._queues[task] = queue_manager.get_queue(q_name) </s> remove     def start_thread(self, task):
        """ Start the DiskIO thread """
 </s> add     def _start_thread(self, task):
        """ Create the thread for the given task, add it it :attr:`self._threads` and start it.

        Parameters
        ----------
        task: {"load", "save"}
            The task that the thread is to be created for
        """ </s> remove         args = self.completion_event if task == "save" else None
        func = getattr(self, task)
 </s> add         args = self._completion_event if task == "save" else None
        func = getattr(self, "_{}".format(task)) </s> remove     def init_threads(self):
        """ Initialize queues and threads """
 </s> add     def _init_threads(self):
        """ Initialize queues and threads.

        Creates the load and save queues and the load and save threads. Starts the threads.
        """
    def _add_queue(self, task):
        """ Add the queue to queue_manager and to :attr:`self._queues` for the given task.

        Parameters
        ----------
        task: {"load", "save"}
            The task that the queue is to be added for
        """
              self.add_queue(task)
              self.start_thread(task)
          logger.debug("Initialized DiskIO Threads")
  
    def _add_queue(self, task):
        """ Add the queue to queue_manager and to :attr:`self._queues` for the given task.

        Parameters
        ----------
        task: {"load", "save"}
            The task that the queue is to be added for
        """
    def _add_queue(self, task):
        """ Add the queue to queue_manager and to :attr:`self._queues` for the given task.

        Parameters
        ----------
        task: {"load", "save"}
            The task that the queue is to be added for
        """
          logger.debug("Adding queue for task: '%s'", task)
          if task == "load":
              q_name = "convert_in"
          elif task == "save":
              q_name = "convert_out"
keep keep keep keep replace replace keep keep keep keep keep
 Smart Masks to Convert (#957)

- scripts.convert - Use Smart Masks for Convert
    * Make on-the-fly conversion an explicit option

- Move BlurMask to lib.faces_detect

- tools.preview - Fix for smart masks
    * Subclass from tk.Tk
    * Options to lib.gui.control_helper
    *variable cleanup

- lib.logger - Demote more tensorflow deprecation messages

- Documentation:
    * lib.faces_detect.BlurMask
    * plugins.convert.mask
    * lib.convert
    * scripts.convert
    * scripts.fsmedia
    * tools.preview 
scripts/convert.py