diff --git a/src/Plugin/AdvancedQueue/Backend/Database.php b/src/Plugin/AdvancedQueue/Backend/Database.php
index 842f27a..2b9080f 100644
--- a/src/Plugin/AdvancedQueue/Backend/Database.php
+++ b/src/Plugin/AdvancedQueue/Backend/Database.php
@@ -2,6 +2,8 @@
 
 namespace Drupal\advancedqueue\Plugin\AdvancedQueue\Backend;
 
+use Drupal\Component\Utility\DeprecationHelper;
+use Drupal\Core\Database\Statement\FetchAs;
 use Drupal\advancedqueue\Attribute\AdvancedQueueBackend;
 use Drupal\advancedqueue\Entity\Queue;
 use Drupal\advancedqueue\Entity\QueueInterface;
@@ -230,7 +232,7 @@ class Database extends BackendBase implements SupportsDeletingJobsInterface, Sup
       $query->condition('job_id', $job->getId(), '<>');
     }
     $result = $query->execute();
-    $job_definitions = $result->fetchAllAssoc('job_id', \PDO::FETCH_ASSOC);
+    $job_definitions = DeprecationHelper::backwardsCompatibleCall(\Drupal::VERSION, '11.2.0', fn() => $result->fetchAllAssoc('job_id', FetchAs::Associative), fn() => $result->fetchAllAssoc('job_id', \PDO::FETCH_ASSOC));
 
     $jobs = [];
     foreach ($job_definitions as $job_id => $job_definition) {
diff --git a/tests/src/Kernel/ProcessorTest.php b/tests/src/Kernel/ProcessorTest.php
index 51e24b1..b06f63e 100644
--- a/tests/src/Kernel/ProcessorTest.php
+++ b/tests/src/Kernel/ProcessorTest.php
@@ -4,6 +4,8 @@ declare(strict_types=1);
 
 namespace Drupal\Tests\advancedqueue\Kernel;
 
+use Drupal\Component\Utility\DeprecationHelper;
+use Drupal\Core\Database\Statement\FetchAs;
 use Drupal\advancedqueue\Entity\Queue;
 use Drupal\advancedqueue\Job;
 use Drupal\KernelTests\KernelTestBase;
@@ -79,7 +81,7 @@ class ProcessorTest extends KernelTestBase {
 
     /** @var \Drupal\Core\Database\Connection $connection */
     $connection = $this->container->get('database');
-    $raw_jobs = $connection->query('SELECT job_id, state, message FROM {advancedqueue}')->fetchAllAssoc('job_id', \PDO::FETCH_ASSOC);
+    $raw_jobs = DeprecationHelper::backwardsCompatibleCall(\Drupal::VERSION, '11.2.0', fn() => $connection->query('SELECT job_id, state, message FROM {advancedqueue}')->fetchAllAssoc('job_id', FetchAs::Associative), fn() => $connection->query('SELECT job_id, state, message FROM {advancedqueue}')->fetchAllAssoc('job_id', \PDO::FETCH_ASSOC));
     $this->assertEquals([
       'job_id' => '1',
       'state' => Job::STATE_SUCCESS,
@@ -130,7 +132,7 @@ class ProcessorTest extends KernelTestBase {
 
     /** @var \Drupal\Core\Database\Connection $connection */
     $connection = $this->container->get('database');
-    $raw_jobs = $connection->query('SELECT job_id, state, num_retries FROM {advancedqueue}')->fetchAllAssoc('job_id', \PDO::FETCH_ASSOC);
+    $raw_jobs = DeprecationHelper::backwardsCompatibleCall(\Drupal::VERSION, '11.2.0', fn() => $connection->query('SELECT job_id, state, num_retries FROM {advancedqueue}')->fetchAllAssoc('job_id', FetchAs::Associative), fn() => $connection->query('SELECT job_id, state, num_retries FROM {advancedqueue}')->fetchAllAssoc('job_id', \PDO::FETCH_ASSOC));
     $this->assertEquals([
       'job_id' => '1',
       'state' => Job::STATE_FAILURE,