drupal queue integration not clearing itself?

So here's an interesting issue and I believe this is a bug in clearing the Drupal queue.

http://www.momblognetwork.com/

We have about 5333 blogs that are being processed. This is backed up by the node table and more importantly, schedule table:

mysql> select count(*) from feeds_schedule;                                     
+----------+
| count(*) |
+----------+
|     5333 | 
+----------+
1 row in set (0.00 sec)

When using Drupal queue, Feeds appears to take each entry from the schedule table, adds to the queue table for processing.

You should never have more items in Drupal queue than Feeds schedule, right? [assuming using no other modules with drupal_queue]

mysql> select count(*) from queue;                                              
+----------+
| count(*) |
+----------+
|    58994 | 
+----------+
1 row in set (0.00 sec)

mysql> select distinct(name) from queue;                                        
+-------------+
| name        |
+-------------+
| feeds_queue | 
+-------------+
1 row in set (0.00 sec)

Seems like something is off here :)

It seems old items are never being deleted out of the queue.

I believe the error is within protected function unschedule($job), it should have this function:

The full queue item returned by DrupalQueueInterface::createItem() needs to be passed to DrupalQueueInterface::deleteItem() once processing is completed.