+
+ self._logger.error("Error occurred while executing task: %s" % err)
+
+ # Mark the EC as failed
+ self._state = ECState.FAILED
+
+ # Wake up the EC in case it was sleeping
+ self._cond.acquire()
+ self._cond.notify()
+ self._cond.release()
+
+ # Propage error to the ParallelRunner
+ raise