@Test
public void shouldCheckIfPodExistsBeforeCreating() throws IOException {

  when(k8sClient.getPod(any())).thenReturn(Optional.of(createdPod));
  kdr.start(RUN_STATE, RUN_SPEC);
  verify(k8sClient).getPod(RUN_SPEC.executionId());
  verifyNoMoreInteractions(k8sClient);
  verifyZeroInteractions(stateManager);
}