diff --git a/app/code/Magento/Cron/Observer/ProcessCronQueueObserver.php b/app/code/Magento/Cron/Observer/ProcessCronQueueObserver.php
index d000f7dbbeb31..e4ecf44830040 100644
--- a/app/code/Magento/Cron/Observer/ProcessCronQueueObserver.php
+++ b/app/code/Magento/Cron/Observer/ProcessCronQueueObserver.php
@@ -398,10 +398,13 @@ function () use ($schedule) {
                     $e
                 );
             }
+            $this->eventManager->dispatch('cron_job_error', ['job_name' => 'cron/' . $groupId . '/' . $jobCode, 'exception' => $e]);
             throw $e;
         } finally {
             $this->stopProfiling($jobCode);
         }
+        
+        $this->eventManager->dispatch('cron_job_success', ['job_name' => 'cron/' . $groupId . '/' . $jobCode]);
 
         $schedule->setStatus(
             Schedule::STATUS_SUCCESS