Method executeBySchedule

lib/Service/DataloadService.php:157–168

* execute all data loads depending on their schedule * Daily or Hourly * * @param $schedule * @return void * @throws Exception */

($schedule)

     * @throws Exception
     */
    public function executeBySchedule($schedule)
    {
        $schedules = $this->DataloadMapper->getDataloadBySchedule($schedule);
        foreach ($schedules as $dataload) {
            $result = $this->execute($dataload['id'], null, false);
            if ($result['error'] !== 0 && $result['insert'] === 0 && $result['update'] === 0) {
                // Only notify when the data load failed completely, not when individual records failed.
                $dataset = $this->DatasetService->read($dataload['dataset']);
                $this->NotificationManager->triggerNotification(NotificationManager::DATALOAD_ERROR, $dataload['dataset'], $dataload['id'], ['dataloadName' => $dataload['name'], 'datasetName' => $dataset['name']], $dataload['user_id']);
            }
        }
    }

    /**
     * execute a data load from data source and store into dataset