def METHOD_NAME():
    from apps.rss_feeds.models import Feed        
    settings.LOG_TO_STREAM = True
    now = datetime.datetime.utcnow()
    start = time.time()
    r = redis.Redis(connection_pool=settings.REDIS_FEED_UPDATE_POOL)
    tasked_feeds_size = r.zcard('tasked_feeds')
    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)
    if not queued_feeds:
        logging.debug(" ---> ~SN~FB~BMNo feeds to queue! Exiting...")
        return
    r.sadd('queued_feeds', *queued_feeds)
    logging.debug(" ---> ~SN~FBQueuing ~SB%s~SN stale feeds (~SB%s~SN/~FG%s~FB~SN/%s tasked/queued/scheduled)" % (
                    len(queued_feeds),
                    r.zcard('tasked_feeds'),
                    r.scard('queued_feeds'),
                    r.zcard('scheduled_updates')))
    # Regular feeds
    if tasked_feeds_size < FEED_TASKING_MAX:
        feeds = r.srandmember('queued_feeds', FEED_TASKING_MAX)
        Feed.task_feeds(feeds, verbose=True)
        active_count = len(feeds)
    else:
        logging.debug(" ---> ~SN~FBToo many tasked feeds. ~SB%s~SN tasked." % tasked_feeds_size)
        active_count = 0
    logging.debug(" ---> ~SN~FBTasking %s feeds took ~SB%s~SN seconds (~SB%s~SN/~FG%s~FB~SN/%s tasked/queued/scheduled)" % (
                    active_count,
                    int((time.time() - start)),
                    r.zcard('tasked_feeds'),
                    r.scard('queued_feeds'),
                    r.zcard('scheduled_updates')))
    logging.debug(" ---> ~FBFeeds being tasked: ~SB%s" % feeds)