}
    }

    @Test
    public void test_multipleJobExecutors() {
        // Test multiple JobExecutor instances
        JobExecutor executor1 = new TestJobExecutor();
        JobExecutor executor2 = new TestJobExecutor();

        AtomicInteger counter1 = new AtomicInteger(0);
        AtomicInteger counter2 = new AtomicInteger(0);

    }

    // Test execute with job executor
    @Test
    public void test_execute_withJobExecutor() {
        pythonJob.filename("test.py");

        TestJobExecutor jobExecutor = new TestJobExecutor();
        pythonJob.jobExecutor = jobExecutor;

        testProcessHelper.exitValue = 0;

        pythonJob.execute();

        assertTrue(jobExecutor.shutdownListenerAdded);
    }

        assertTrue(ComponentUtil.hasIngestFactory());
    }

    @Test
    public void test_getJobExecutor_withSuffix() {
        try {
            ComponentUtil.getJobExecutor("testJobExecutor");
            fail("Should throw exception");
        } catch (Exception e) {
            // Expected
        }
    }

    @Test
    public void test_getJobExecutor_withoutSuffix() {

            return null;
        }

        @Override
        public void setResponseCharacterEncoding(String encoding) {
        }
    }

    private static class TestJobExecutor extends JobExecutor {
        boolean shutdownListenerAdded = false;

        @Override
        public void addShutdownListener(ShutdownListener listener) {
            shutdownListenerAdded = true;