@Test
    void testTranslationTaskFactory() {
        // Create a store.
        createStore(VALID_DATA, REFERENCE_DATA, SAMPLE_XSLT);

        assertThat(metaService.getLockCount())
                .isEqualTo(0);

        // Process the store sequentially.
        final List<ProcessorResult> results = processAll();

        assertThat(results.size())
                .as("Check that we did the number of jobs expected")
                .isEqualTo(NO_OF_REFERENCE_FILES + NO_OF_EVENT_FILES);
        assertThat(metaService.getLockCount())
                .isEqualTo(0);

        // Check we have some raw events.
        final List<Meta> raw = metaService.find(FindMetaCriteria.createWithType(StreamTypeNames.RAW_EVENTS))
                .getValues();
        assertThat(raw.size())
                .isEqualTo(NO_OF_EVENT_FILES);

        // Check all passed.
        final List<Meta> cooked = metaService.find(FindMetaCriteria.createWithType(StreamTypeNames.EVENTS))
                .getValues();
        assertThat(cooked.size())
                .isEqualTo(NO_OF_EVENT_FILES);

        // Check none failed.
        for (final ProcessorResult result : results) {
            assertThat(result.getMarkerCount(Severity.SEVERITIES))
                    .isEqualTo(0);
        }
    }
Tests that valid streams are all processed and put into the processed and
raw stores and that no streams end up in the error store.
stroom-app/src/test/java/stroom/pipeline/task/TestTranslationTaskFactory.java