diff --git a/apps/profile/tasks.py b/apps/profile/tasks.py
index 3f8bcfe7c..efd4fd4c6 100644
--- a/apps/profile/tasks.py
+++ b/apps/profile/tasks.py
@@ -52,6 +52,7 @@ class CleanupUser(Task):
     
     def run(self, user_id):
         UserSubscription.trim_user_read_stories(user_id)
+        UserSubscription.verify_verify_feeds_scheduled(user_id)
 
         if random.random() < 0.01:
             ss = MSocialServices.objects.get(user_id=user_id)
diff --git a/apps/reader/models.py b/apps/reader/models.py
index 3c332f5fd..be869b304 100644
--- a/apps/reader/models.py
+++ b/apps/reader/models.py
@@ -829,8 +829,9 @@ class UserSubscription(models.Model):
             usf.save()
     
     @classmethod
-    def verify_feeds_scheduled(cls, user):
+    def verify_feeds_scheduled(cls, user_id):
         r = redis.Redis(connection_pool=settings.REDIS_FEED_POOL)
+        user = User.objects.get(pk=user_id)
         subs = cls.objects.filter(user=user)
         feed_ids = [sub.feed.pk for sub in subs]