old_contents: """
  Celery tasks for Batch operations.
  """
  
  import os
  import glob
  from celery.contrib.abortable import AbortableTask
  from celery.task.sets import subtask
  from ocradmin.ocrtasks.decorators import register_handlers
  from ocradmin.ocrtasks.utils import get_progress_callback, get_abort_callback
  from django.utils import simplejson as json
  
  from nodetree import cache, node, script
  from nodetree.manager import ModuleManager
  from django.conf import settings
  from ocradmin.plugins import ocropus_nodes, stages
  
  MANAGER = ModuleManager()
  MANAGER.register_paths(
                  glob.glob("plugins/*_nodes.py"), root="ocradmin")
  
  
  @register_handlers
  class BatchScriptTask(AbortableTask):
      name = "run.batchitem"
  
      def run(self, filepath, scriptjson, writepath, callback=None):
          """
          Runs the convert action.
          """
          logger = self.get_logger()
          logger.debug("Running Batch with callback: %s", callback)
          progress_handler = get_progress_callback(self.request.id)
          abort_handler = get_abort_callback(self.request.id)
          progress_handler(0)
  
          tree = script.Script(json.loads(scriptjson), manager=MANAGER, 
                  nodekwargs=dict(
                      logger=logger,
                      abort_func=abort_handler, 
                      progress_func=progress_handler))
          logger.debug("Running tree: %s", json.dumps(tree.serialize(), indent=2))                
          term = [t for t in tree.get_terminals() if t.label != "OutputBinary"][0]
          outbin = tree.get_node("OutputBinary")
          try:
              # write out the binary... this should cache it's input
              os.environ["NODETREE_WRITE_FILEOUT"] = "1"
              outbin.eval()
              result = term.eval()
              if callback is not None:
                  subtask(callback).delay(result)
              return result
          except ocropus_nodes.OcropusNodeError, err:
              logger.error("Ocropus Node Error (%s): %s", err.node, err.message)
              return dict(type="error", node=err.node.label, error=err.msg)
          except Exception, err:
              logger.error("Unhandled exception: %s", err)
              return dict(error=err.msg)
              
  
new_contents: """
  Celery tasks for Batch operations.
  """
  
  import os
  import glob
  from celery.contrib.abortable import AbortableTask
  from celery.task.sets import subtask
  from ocradmin.ocrtasks.decorators import register_handlers
  from ocradmin.ocrtasks.utils import get_progress_callback, get_abort_callback
  from django.utils import simplejson as json
  
  from nodetree import cache, node, script
  from nodetree.manager import ModuleManager
  from django.conf import settings
  from ocradmin.plugins import ocropus_nodes, stages
  
  MANAGER = ModuleManager()
  MANAGER.register_paths(
                  glob.glob("plugins/*_nodes.py"), root="ocradmin")
  
  
  @register_handlers
  class BatchScriptTask(AbortableTask):
      name = "run.batchitem"
  
      def run(self, filepath, scriptjson, writepath, callback=None):
          """
          Runs the convert action.
          """
          logger = self.get_logger()
          logger.debug("Running Batch with callback: %s", callback)
          progress_handler = get_progress_callback(self.request.id)
          abort_handler = get_abort_callback(self.request.id)
          progress_handler(0)
  
          tree = script.Script(json.loads(scriptjson), manager=MANAGER, 
                  nodekwargs=dict(
                      logger=logger,
                      abort_func=abort_handler, 
                      progress_func=progress_handler))
          logger.debug("Running tree: %s", json.dumps(tree.serialize(), indent=2))                
          term = [t for t in tree.get_terminals() if t.label != "OutputBinary"][0]
          outbin = tree.get_node("OutputBinary")
          try:
              # write out the binary... this should cache it's input
              os.environ["NODETREE_WRITE_FILEOUT"] = "1"
              outbin.eval()
              result = term.eval()
              if callback is not None:
                  subtask(callback).delay(result)
              return result
          except ocropus_nodes.OcropusNodeError, err:
              logger.error("Ocropus Node Error (%s): %s", err.node, err.message)
              return dict(type="error", node=err.node.label, error=err.message)
          except Exception, err:
              logger.error("Unhandled exception: %s", err)
              return dict(error=err.message)
              
  
subject: Replace usage of 'msg' with 'message'