Recover from database failures when reading the workflow store.

broadinstitute · Apr 5, 2017 · 62c66e7 · 62c66e7
1 parent caab258
commit 62c66e7
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/engine/src/main/scala/cromwell/engine/workflow/workflowstore/WorkflowStoreEngineActor.scala b/engine/src/main/scala/cromwell/engine/workflow/workflowstore/WorkflowStoreEngineActor.scala
@@ -129,6 +129,11 @@ final case class WorkflowStoreEngineActor(store: WorkflowStore, serviceRegistryA
     runnableWorkflows map {
       case x :: xs => NewWorkflowsToStart(NonEmptyList.of(x, xs: _*))
       case _ => NoNewWorkflowsToStart
+    } recover {
+      case e =>
+        // Log the error but return a successful Future so as not to hang future workflow store polls.
+        log.error(e, "Error trying to fetch new workflows")
+        NoNewWorkflowsToStart
     }
   }
 }