diff --git a/concurrent_queue.drush.inc b/concurrent_queue.drush.inc
index 7e44360..5b0cc5f 100644
--- a/concurrent_queue.drush.inc
+++ b/concurrent_queue.drush.inc
@@ -209,20 +209,27 @@ class DrushConcurrentQueue {
       return $this->queue->reclaimItems();
     }
     elseif (is_a($this->queue, 'SystemQueue')) {
-      // If a parent queue is being run, reclaim all un-run and expired items
-      // assigned to subqueues or the parent queue.
-      $query = db_update('queue');
-      $query->fields(array('expire' => 0, 'name' => $this->name));
-      $expire_condition = db_or();
-      $expire_condition->condition('expire', 0);
-      $expire_condition->condition('expire', time(), '<');
-      $query->condition($expire_condition);
-      $name_condition = db_or();
-      $name_condition->condition('name', $this->name);
-      // Deprecated support for when the subqueues had different names.
-      $name_condition->condition('name', db_like($this->name . ':') . '%', 'LIKE');
-      $query->condition($name_condition);
-      return $query->execute();
+      try {
+        // If a parent queue is being run, reclaim all un-run and expired items
+        // assigned to subqueues or the parent queue.
+        $query = db_update('queue');
+        $query->fields(array('expire' => 0, 'name' => $this->name));
+        $expire_condition = db_or();
+        $expire_condition->condition('expire', 0);
+        $expire_condition->condition('expire', time(), '<');
+        $query->condition($expire_condition);
+        $name_condition = db_or();
+        $name_condition->condition('name', $this->name);
+        // Deprecated support for when the subqueues had different names.
+        $name_condition->condition('name', db_like($this->name . ':') . '%', 'LIKE');
+        $query->condition($name_condition);
+        return $query->execute();
+      }
+      catch (PDOException $e) {
+        drush_log(dt("Unable to reclaim items for queue $this->name."), 'warning');
+        drush_log($e->getMessage());
+        return FALSE;
+      }
     }
     else {
       drush_log(dt("Unable to reclaim items for queue $this->name since it does not use or extend the SystemQueue class."), 'warning');