@Test
void publishError() throws IOException {

    when(kubeClient.listPods("ns")).thenThrow(new Error("mock"));
    job.execute(null);
    verify(publisher).publish(argThat(message -> "kubernetes".equals(message.app)
            && "ERROR".equals(message.result)
            && "FAILED_TO_COLLECT".equals(message.errorCode)));
}