// Verify ingester was called
        assertEquals(1, ingester.processCalled);
        assertEquals("processed", result.get("status"));
    }

    @Test
    public void test_ingest_withException() {
        // Setup ingester that throws exception
        TestIngester failingIngester = new TestIngester() {
            @Override

        // Result should be the same as input doc when ingester is null or doesn't modify
        assertSame(doc, result);
    }

    // Test ingest with exception in ingester
    @Test
    public void test_ingest_withException() {
        final TestIngestFactory factory = (TestIngestFactory) ingestFactory;
        factory.setThrowException(true);

        final Map<String, Object> doc = new HashMap<>();