diff --git a/src/operators/deferred_job_result.py b/src/operators/deferred_job_result.py
index c2ee8f6..e13177d 100644
--- a/src/operators/deferred_job_result.py
+++ b/src/operators/deferred_job_result.py
@@ -62,7 +62,11 @@ def execute(self, context, session=None, event=None):
                 self.log.info('Waiting for task "%s" to reach state %s...', str(task), self.wait_for_state)
 
         if task.state == State.FAILED:
-            raise ErgoFailedResultException(400, "Cron execution failed")
+            if job is not None:
+                self.log.info('Job - (%s)' + (f'responded back at {job.response_at}' if job.response_at else ''), str(job))
+                raise ErgoFailedResultException(job.result_code, job.error_msg)
+            else:
+                raise ErgoFailedResultException(400, "Cron execution failed due to unknown reason")
 
         self.log.info('Task - %s reached state %s', str(task), task.state)
         return