diff --git a/src/Worker/ArchiveWorker.php b/src/Worker/ArchiveWorker.php index 570693f..9225f4a 100644 --- a/src/Worker/ArchiveWorker.php +++ b/src/Worker/ArchiveWorker.php @@ -62,10 +62,10 @@ public function __invoke(Job $job) $this->_ensureTable($archiveTable); $connection = $archiveTable->getConnection(); - $quote = $connection->driver() - ->autoQuoting(); - $connection->driver() - ->autoQuoting(true); + $quote = $connection->getDriver() + ->isAutoQuotingEnabled(); + $connection->getDriver() + ->enableAutoQuoting(true); $selectQuery = $delayedJobsTable->query() ->where(['status IN' => [Job::STATUS_BURIED, Job::STATUS_SUCCESS]]); @@ -91,8 +91,8 @@ public function __invoke(Job $job) Log::debug('Archive cleaned.'); } - $connection->driver() - ->autoQuoting($quote); + $connection->getDriver() + ->enableAutoQuoting($quote); return new Time(Configure::read('DelayedJobs.archive.recurring')); }