@Override
    public CompletableFuture<JobResourceRequirements> requestJobResourceRequirements() {
        return CompletableFuture.completedFuture(schedulerNG.requestJobResourceRequirements());
    }
@Test
    public void testResourceRequirementsAreRequestedFromTheScheduler() throws Exception {
        final JobResourceRequirements jobResourceRequirements = JobResourceRequirements.empty();
        final TestingSchedulerNG scheduler =
                TestingSchedulerNG.newBuilder()
                        .setRequestJobResourceRequirementsSupplier(() -> jobResourceRequirements)
                        .build();
        try (final JobMaster jobMaster =
                new JobMasterBuilder(jobGraph, rpcService)
                        .withSlotPoolServiceSchedulerFactory(
                                DefaultSlotPoolServiceSchedulerFactory.create(
                                        TestingSlotPoolServiceBuilder.newBuilder(),
                                        new TestingSchedulerNGFactory(scheduler)))
                        .createJobMaster()) {
            jobMaster.start();
            final JobMasterGateway jobMasterGateway =
                    jobMaster.getSelfGateway(JobMasterGateway.class);
            assertThatFuture(jobMasterGateway.requestJobResourceRequirements())
                    .eventuallySucceeds()
                    .isEqualTo(jobResourceRequirements);
        }
    }