@Override
    public ExecutionState getState() {
        return stateSupplier.get();
    }
@Test
    void testGetExecutionState() {
        for (ExecutionState state : ExecutionState.values()) {
            stateSupplier.setExecutionState(state);
            assertThat(producerVertex.getState()).isEqualTo(state);
        }
    }