@Test(expected = CompletionException.class)
public void testError() {

    // Mock task
    final ChainableSupplier<SparkJobResponse> task = () -> {
        throw new UnsupportedOperationException();
    };
    // Test subscribing
    final DefaultSparkJobContext context = DefaultSparkJobContext.create(task, cache, executor);
    take(context);
}