@Override
    public CompletableFuture<Void> localCleanupAsync(JobID jobId, Executor unusedExecutor) {
        if (isRegistered(jobId)) {
            return unregister(jobId).closeAsync();
        }

        return FutureUtils.completedVoidFuture();
    }
@Test
    void testLocalCleanupAsyncOnUnknownJobId() {
        assertThat(testInstance.localCleanupAsync(new JobID(), Executors.directExecutor()))
                .isCompleted();
    }