  
          logger.debug("Postprocess Items: %s", postprocess_items)
          return postprocess_items
  
      def do_actions(self, output_item):
          """ Perform the requested post-processing actions """
          for action in self.actions:
              logger.debug("Performing postprocess action: '%s'", action.__class__.__name__)
              action.process(output_item)
  
 
</s> remove             action.process(output_item)
 </s> add             action.process(extract_media) </s> remove     def process(self, output_item):
 </s> add     def process(self, extract_media): </s> remove     def process(self, output_item):
 </s> add     def process(self, extract_media): </s> remove         self.valid = True  # Set to False if invalid params passed in to disable
 </s> add         self.valid = True  # Set to False if invalid parameters passed in to disable </s> remove 
    @staticmethod
    def _remove_invalid_keys(dictionary, valid_keys):
        """ Remove items from dict that are no longer required """
        for key in list(dictionary.keys()):
            if key not in valid_keys:
                logger.trace("Removing from output: '%s'", key)
                del dictionary[key]
 </s> add 
    def do_actions(self, extract_media):
  
          logger.debug("Postprocess Items: %s", postprocess_items)
          return postprocess_items
  
    def do_actions(self, extract_media):
          """ Perform the requested post-processing actions """
          for action in self.actions:
              logger.debug("Performing postprocess action: '%s'", action.__class__.__name__)
              action.process(output_item)
  
keep keep keep keep replace keep keep keep keep keep
 plugins.extract - Create ExtractMedia class for pipeline flow
Bugfix - Fix memory leak in extract 
scripts/fsmedia.py