@VisibleForTesting
    static CPUResource getDefaultCpus(Configuration configuration) {
        double fallback = configuration.get(KubernetesConfigOptions.TASK_MANAGER_CPU);
        return TaskExecutorProcessUtils.getCpuCoresWithFallback(configuration, fallback);
    }
@Test
    void testGetCpuCoresNumSlots() {
        final Configuration configuration = new Configuration();
        configuration.set(TaskManagerOptions.NUM_TASK_SLOTS, 3);

        assertThat(KubernetesWorkerResourceSpecFactory.getDefaultCpus(configuration))
                .isEqualTo(new CPUResource(3.0));
    }