From 9ee3c5d1da8e4b4ec22aeed6eb918665046de550 Mon Sep 17 00:00:00 2001
From: mbaxter <mbaxter@users.noreply.github.com>
Date: Tue, 5 Mar 2019 18:32:22 -0500
Subject: [PATCH] Don't log expected failures as errors (#1054)

Signed-off-by: Adrian Sutton <adrian.sutton@consensys.net>
---
 .../ethereum/eth/manager/task/AbstractPipelinedTask.java  | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/task/AbstractPipelinedTask.java b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/task/AbstractPipelinedTask.java
index c995e4a0af..1cb44a8a73 100644
--- a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/task/AbstractPipelinedTask.java
+++ b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/manager/task/AbstractPipelinedTask.java
@@ -12,9 +12,11 @@
  */
 package tech.pegasys.pantheon.ethereum.eth.manager.task;
 
+import tech.pegasys.pantheon.ethereum.eth.manager.exceptions.EthTaskException;
 import tech.pegasys.pantheon.metrics.Counter;
 import tech.pegasys.pantheon.metrics.MetricCategory;
 import tech.pegasys.pantheon.metrics.MetricsSystem;
+import tech.pegasys.pantheon.util.ExceptionUtils;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -119,9 +121,13 @@ public abstract class AbstractPipelinedTask<I, O> extends AbstractEthTask<List<O
   }
 
   protected void failExceptionally(final Throwable t) {
-    if (!(t instanceof InterruptedException)) {
+    Throwable rootCause = ExceptionUtils.rootCause(t);
+    if (rootCause instanceof InterruptedException || rootCause instanceof EthTaskException) {
+      LOG.debug("Task Failure: {}", t.toString());
+    } else {
       LOG.error("Task Failure", t);
     }
+
     processingException.compareAndSet(null, t);
     result.get().completeExceptionally(t);
     cancel();