@Test
    void test() {
        // FIXME : Fix this.

        // setup();
        // assertThat(streamStore.getLockCount()).isEqualTo(0);
        //
        // final List<TranslationTaskResult> results = doTest();
        // assertThat(results.size()).isEqualTo(1);
        // for (final TranslationTaskResult result : results) {
        // Assert
        // .assertThat(// result.getRecordsWritten() > 0).as(result.toString()).isTrue();
        // assertThat(// result.getRecordsRead() <= result.getRecordsWritten()).as(result.toString()).isTrue();
        // assertThat(result
        // .getRecordsWarning()).as(result.toString()).isEqualTo(0);
        // assertThat(result.getRecordsError()).as(result.toString()).isEqualTo(0);
        // }
        //
        // for (final Stream stream : streamStore.getFileData().keySet()) {
        // if (stream.getType() == StreamType.EVENTS) {
        // final byte[] data = streamStore.getFileData().get(stream).loadByName(
        // stream.getType());
        //
        // StreamUtil.stringToStream(new String(data),
        // StroomProcessTestFileUtil.getOutputStream(OUTPUT));
        // }
        // }
        //
        // // Make sure 1 record was written.
        // assertThat(results.loadByName(0).getRecordsWritten()).isEqualTo(1);
        //
        // // Compare all files.
        // ComparisonHelper.compareFiles(StroomProcessTestFileUtil
        // .getTestDataDir().resolve(DIR));
        //
        // // Make sure flattening dir exists.
        // final Path flatteningDir = StroomProcessTestFileUtil
        // .getTestDataDir().resolve(FLATTENING_DIR);
        // assertThat(Files.isDirectory(flatteningDir)).isTrue();
        // final Path flatFile = flatteningDir.resolve("2_STROOM.out");
        // assertThat(Files.isRegularFile(flatFile)).isTrue();
    }
Tests Task with a valid resource and feed.
stroom-app/src/test/java/stroom/pipeline/task/TestTranslationTaskContextAndFlattening.java