Add a delete_expired_ttl (jobs) method to queue and have it called when the worker connection times out.