diff --git a/app/Jobs/Ninja/TaskScheduler.php b/app/Jobs/Ninja/TaskScheduler.php index 69862f8877c2..f4a6104d1a07 100644 --- a/app/Jobs/Ninja/TaskScheduler.php +++ b/app/Jobs/Ninja/TaskScheduler.php @@ -42,6 +42,23 @@ class TaskScheduler implements ShouldQueue */ public function handle() { + + if (! config('ninja.db.multi_db_enabled')) { + + Scheduler::with('company') + ->where('is_paused', false) + ->where('is_deleted', false) + ->whereNotNull('next_run') + ->where('next_run', '<=', now()) + ->cursor() + ->each(function ($scheduler) { + $this->doJob($scheduler); + }); + + + return; + } + foreach (MultiDB::$dbs as $db) { MultiDB::setDB($db);