MAGETWO-39778: Reindex by cron cannot finish: "Area code not set"

- fixed unit tests

Author: Olga Kopylova

app/code/Magento/Cron/Model/Observer.php

@@ -182,7 +182,6 @@ public function dispatch($observer)
                     }
                 } catch (\Exception $e) {
                     $schedule->setMessages($e->getMessage());
-                    $schedule->setStatus(Schedule::STATUS_ERROR);
                 }
                 $schedule->save();
             }
@@ -230,7 +229,12 @@ protected function _runJob($scheduledTime, $currentTime, $jobConfig, $schedule,
 
         $schedule->setExecutedAt(strftime('%Y-%m-%d %H:%M:%S', $this->timezone->scopeTimeStamp()))->save();
 
-        call_user_func_array($callback, [$schedule]);
+        try {
+            call_user_func_array($callback, [$schedule]);
+        } catch (\Exception $e) {
+            $schedule->setStatus(Schedule::STATUS_ERROR);
+            throw $e;
+        }
 
         $schedule->setStatus(Schedule::STATUS_SUCCESS)->setFinishedAt(strftime(
             '%Y-%m-%d %H:%M:%S',

app/code/Magento/Cron/Test/Unit/Model/CronJobException.php

@@ -0,0 +1,19 @@
+<?php
+/**
+ * Copyright © 2015 Magento. All rights reserved.
+ * See COPYING.txt for license details.
+ */
+
+/**
+ * Class CronJobException used to check that cron handles execution exception
+ * Please see \Magento\Cron\Test\Unit\Model\ObserverTest
+ */
+namespace Magento\Cron\Test\Unit\Model;
+
+class CronJobException
+{
+    public function execute()
+    {
+        throw new \Exception('Test exception');
+    }
+}

app/code/Magento/Cron/Test/Unit/Model/ObserverTest.php

@@ -293,37 +293,36 @@ public function testDispatchExceptionNoCallback()
     }
 
     /**
-     * Test case catch exception if callback exists but can't be executed
+     * Test case catch exception if callback is not callable or throws exception
+     *
+     * @param string $cronJobType
+     * @param mixed $cronJobObject
+     * @param string $exceptionMessage
+     * @param int $saveCalls
+     *
+     * @dataProvider dispatchExceptionInCallbackDataProvider
      */
-    public function testDispatchExceptionNotExecutable()
+    public function testDispatchExceptionInCallback($cronJobType, $cronJobObject, $exceptionMessage, $saveCalls)
     {
         $jobConfig = [
             'test_group' => [
-                'test_job1' => ['instance' => 'Not_Existed_Class', 'method' => 'notExistedMethod'],
+                'test_job1' => ['instance' => $cronJobType, 'method' => 'execute'],
             ],
         ];
 
-        $exceptionMessage = 'Invalid callback: Not_Existed_Class::notExistedMethod can\'t be called';
         $this->_request->expects($this->any())->method('getParam')->will($this->returnValue('test_group'));
-        $schedule = $this->getMockBuilder(
-            'Magento\Cron\Model\Schedule'
-        )->setMethods(
-            ['getJobCode', 'tryLockJob', 'getScheduledAt', 'save', 'setStatus', 'setMessages', '__wakeup']
-        )->disableOriginalConstructor()->getMock();
+        $schedule = $this->getMockBuilder('Magento\Cron\Model\Schedule')
+            ->setMethods(['getJobCode', 'tryLockJob', 'getScheduledAt', 'save', 'setStatus', 'setMessages', '__wakeup'])
+            ->disableOriginalConstructor()->getMock();
         $schedule->expects($this->any())->method('getJobCode')->will($this->returnValue('test_job1'));
         $schedule->expects($this->once())->method('getScheduledAt')->will($this->returnValue('-1 day'));
         $schedule->expects($this->once())->method('tryLockJob')->will($this->returnValue(true));
-        $schedule->expects(
-            $this->once()
-        )->method(
-            'setStatus'
-        )->with(
-            $this->equalTo(\Magento\Cron\Model\Schedule::STATUS_ERROR)
-        )->will(
-            $this->returnSelf()
-        );
+        $schedule->expects($this->once())
+            ->method('setStatus')
+            ->with($this->equalTo(\Magento\Cron\Model\Schedule::STATUS_ERROR))
+            ->will($this->returnSelf());
         $schedule->expects($this->once())->method('setMessages')->with($this->equalTo($exceptionMessage));
-        $schedule->expects($this->once())->method('save');
+        $schedule->expects($this->exactly($saveCalls))->method('save');
 
         $this->_collection->addItem($schedule);
 
@@ -336,25 +335,41 @@ public function testDispatchExceptionNotExecutable()
         $scheduleMock = $this->getMockBuilder('Magento\Cron\Model\Schedule')->disableOriginalConstructor()->getMock();
         $scheduleMock->expects($this->any())->method('getCollection')->will($this->returnValue($this->_collection));
         $this->_scheduleFactory->expects($this->once())->method('create')->will($this->returnValue($scheduleMock));
-        $this->_objectManager->expects(
-            $this->once()
-        )->method(
-            'create'
-        )->with(
-            $this->equalTo('Not_Existed_Class')
-        )->will(
-            $this->returnValue('')
-        );
+        $this->_objectManager
+            ->expects($this->once())
+            ->method('create')
+            ->with($this->equalTo($cronJobType))
+            ->will($this->returnValue($cronJobObject));
 
         $this->_observer->dispatch('');
     }
 
+    /**
+     * @return array
+     */
+    public function dispatchExceptionInCallbackDataProvider()
+    {
+        return [
+            'non-callable callback' => [
+                'Not_Existed_Class',
+                '',
+                'Invalid callback: Not_Existed_Class::execute can\'t be called',
+                1
+            ],
+            'exception in execution' => [
+                'CronJobException',
+                new \Magento\Cron\Test\Unit\Model\CronJobException(),
+                'Test exception',
+                2
+            ],
+        ];
+    }
+
     /**
      * Test case, successfully run job
      */
     public function testDispatchRunJob()
     {
-        require_once __DIR__ . '/CronJob.php';
         $testCronJob = new \Magento\Cron\Test\Unit\Model\CronJob();
 
         $jobConfig = [