"""
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)

        if not os.path.exists(writepath):
            os.makedirs(writepath, 0777)

        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
            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)
            

@@ -1725,16 +1725,71 @@
 s input%0A
+            os.environ%5B%22NODETREE_WRITE_FILEOUT%22%5D = %221%22%0A
         

Make sure we set the env var when running batches that safe files