8f8c88ca472f10b643f539bbc12edc4cf998bdae,apps/rss_feeds/tasks.py,TaskFeeds,run,#TaskFeeds#,14

Before Change

        
        // Mistakenly inactive feeds
        day = now - datetime.timedelta(days=1)
        inactive_feeds = Feed.objects.filter(
            next_scheduled_update__lte=day,
            min_to_decay__lte=60*24,
            active_subscribers__gte=1
        ).order_by("?")[:100]
        inactive_count = inactive_feeds.count()
        cp3 = time.time()
        
        old = now - datetime.timedelta(days=3)

After Change

        now = datetime.datetime.utcnow()
        start = time.time()
        r = redis.Redis(connection_pool=settings.REDIS_FEED_POOL)
        task_feeds_size = r.llen("update_feeds") * 12
        
        hour_ago = now - datetime.timedelta(hours=1)
        r.zremrangebyscore("fetched_feeds_last_hour", 0, int(hour_ago.strftime("%s")))
        
        now_timestamp = int(now.strftime("%s"))
        queued_feeds = r.zrangebyscore("scheduled_updates", 0, now_timestamp)
        r.zremrangebyscore("scheduled_updates", 0, now_timestamp)
        r.sadd("queued_feeds", *queued_feeds)
        logging.debug(" ---> ~SN~FBQueuing ~SB%s~SN stale feeds (~SB%s~SN/%s queued/scheduled)" % (
                        len(queued_feeds),
                        r.scard("queued_feeds"),
                        r.zcard("scheduled_updates")))
        
        // Regular feeds
        if task_feeds_size < 1000:
            feeds = r.srandmember("queued_feeds", 1000)
            Feed.task_feeds(feeds, verbose=True)
            active_count = len(feeds)
        else:
            active_count = 0
        cp1 = time.time()
        
        // Force refresh feeds
        refresh_feeds = Feed.objects.filter(

Instances