Mercurial > piecrust2
view tests/test_processing_tree.py @ 414:c4b3a7fd2f87
bake: Make pipeline processing multi-process.
Not many changes here, as it's pretty straightforward, but an API change for
processors so they know if they're being initialized/disposed from the main
process or from one of the workers. This makes it possible to do global stuff
that has side-effects (e.g. create a directory) vs. doing in-memory stuff.
author | Ludovic Chabant <ludovic@chabant.com> |
---|---|
date | Sat, 20 Jun 2015 19:20:30 -0700 |
parents | f485ba500df3 |
children | 72f17534d58e |
line wrap: on
line source
from piecrust.processing.base import CopyFileProcessor, SimpleFileProcessor from piecrust.processing.tree import ProcessingTreeBuilder, ProcessingTreeNode class MockProcessor(SimpleFileProcessor): def __init__(self): super(MockProcessor, self).__init__({'mock': 'out'}) self.processed = [] def _doProcess(self, in_path, out_path): self.processed.append((in_path, out_path)) mock_processors = [MockProcessor(), CopyFileProcessor()] IDX_MOCK = 0 IDX_COPY = 1 def test_mock_node(): node = ProcessingTreeNode('/foo.mock', list(mock_processors)) assert node.getProcessor() == mock_processors[IDX_MOCK] def test_copy_node(): node = ProcessingTreeNode('/foo.other', list(mock_processors)) assert node.getProcessor() == mock_processors[IDX_COPY] def test_build_simple_tree(): builder = ProcessingTreeBuilder(mock_processors) root = builder.build('/foo.mock') assert root is not None assert root.getProcessor() == mock_processors[IDX_MOCK] assert not root.is_leaf assert len(root.outputs) == 1 out = root.outputs[0] assert out.getProcessor() == mock_processors[IDX_COPY]