@Test public void testEmptyInstanceTypeIsIgnored() { Pair<V1Affinity, Map<String, String>> affinityWithAnnotations = factory.buildV1Affinity( newJobWithHardConstraint(JobConstraints.MACHINE_TYPE, ""), JobGenerator.oneBatchTask() ); assertThat(affinityWithAnnotations.getLeft().getNodeAffinity()).isNull(); }
@Override public Pair<V1Affinity, Map<String, String>> buildV1Affinity(Job<?> job, Task task) { return new Processor(job).build(); }
DefaultPodAffinityFactory implements PodAffinityFactory { @Override public Pair<V1Affinity, Map<String, String>> buildV1Affinity(Job<?> job, Task task) { return new Processor(job).build(); } }
DefaultPodAffinityFactory implements PodAffinityFactory { @Override public Pair<V1Affinity, Map<String, String>> buildV1Affinity(Job<?> job, Task task) { return new Processor(job).build(); } @Inject  DefaultPodAffinityFactory(DirectKubeConfiguration configuration,
                                     PodResourcePoolResolver podResourcePoolResolver); }
DefaultPodAffinityFactory implements PodAffinityFactory { @Override public Pair<V1Affinity, Map<String, String>> buildV1Affinity(Job<?> job, Task task) { return new Processor(job).build(); } @Inject  DefaultPodAffinityFactory(DirectKubeConfiguration configuration,
                                     PodResourcePoolResolver podResourcePoolResolver); @Override Pair<V1Affinity, Map<String, String>> buildV1Affinity(Job<?> job, Task task); }
DefaultPodAffinityFactory implements PodAffinityFactory { @Override public Pair<V1Affinity, Map<String, String>> buildV1Affinity(Job<?> job, Task task) { return new Processor(job).build(); } @Inject  DefaultPodAffinityFactory(DirectKubeConfiguration configuration,
                                     PodResourcePoolResolver podResourcePoolResolver); @Override Pair<V1Affinity, Map<String, String>> buildV1Affinity(Job<?> job, Task task);  }