public static Executor scopeToJob(JobID jobID, Executor executor) {
        checkArgument(!(executor instanceof MdcAwareExecutor));
        return new MdcAwareExecutor<>(executor, asContextData(jobID));
    }
@Test
    void testScopeScheduledExecutorService() throws Exception {
        ScheduledExecutorService ses =
                java.util.concurrent.Executors.newSingleThreadScheduledExecutor();
        try {
            assertJobIDLogged(
                    jobID ->
                            MdcUtils.scopeToJob(jobID, ses)
                                    .schedule(LOGGING_RUNNABLE, 1L, TimeUnit.MILLISECONDS)
                                    .get());
        } finally {
            ses.shutdownNow();
        }
    }