CompletableFuture<String> getOperationFuture() {
        return operationFuture;
    }
@Test
    void testJobFinishedBeforeSavepointFuture() throws Exception {
        try (MockStopWithSavepointContext ctx = new MockStopWithSavepointContext()) {
            StateTrackingMockExecutionGraph mockExecutionGraph =
                    new StateTrackingMockExecutionGraph();
            CompletableFuture<String> savepointFuture = new CompletableFuture<>();

            StopWithSavepoint sws =
                    createStopWithSavepoint(ctx, mockExecutionGraph, savepointFuture);
            ctx.setStopWithSavepoint(sws);
            ctx.setExpectFinished(assertNonNull());

            mockExecutionGraph.completeTerminationFuture(JobStatus.FINISHED);

            savepointFuture.complete(SAVEPOINT_PATH);
            ctx.triggerExecutors();

            assertThat(sws.getOperationFuture().get()).isEqualTo(SAVEPOINT_PATH);
        }
    }