@Test
public void testInValidCustomBucket() {

    when(validationClient.validateS3BucketAccess(any())).thenReturn(
            Mono.just(S3BucketAccessValidationResponse.newBuilder()
                    .setFailures(ComputeValidator.ValidationFailures.newBuilder()
                            .addFailures(ComputeValidator.ValidationFailure.getDefaultInstance())
                            .build()
                    )
                    .build()
            )
    );
    Set<ValidationError> result = validator.validate(JOB_WITH_CUSTOM_BUCKET).block();
    assertThat(result).hasSize(1);
    verify(validationClient, times(1)).validateS3BucketAccess(any());
}