Handling bunk feeds better by forcing a sub recount and ignoring if not subscribed.

This commit is contained in:
Samuel Clay 2016-02-09 16:34:59 -08:00
parent 39b29bfd27
commit 4ed51e880a
2 changed files with 6 additions and 1 deletions

View file

@ -550,6 +550,7 @@ class Feed(models.Model):
try:
self.feed_address = feed_address
feed = self.save()
feed.count_subscribers()
feed.schedule_feed_fetch_immediately()
feed.has_feed_exception = False
feed.active = True
@ -1737,6 +1738,10 @@ class Feed(models.Model):
def schedule_feed_fetch_immediately(self, verbose=True):
r = redis.Redis(connection_pool=settings.REDIS_FEED_UPDATE_POOL)
if not self.num_subscribers:
logging.debug(' ---> [%-30s] Not scheduling feed fetch immediately, no subs.' % (unicode(self)[:30]))
return
if verbose:
logging.debug(' ---> [%-30s] Scheduling feed fetch immediately...' % (unicode(self)[:30]))

View file

@ -40,7 +40,7 @@ def main(role="app", role2="work", command=None, path=None):
def create_streams_for_roles(role, role2, command=None, path=None):
streams = list()
hosts = fabfile.do(split=True)
hosts = fabfile.assign_digitalocean_roledefs(split=True)
found = set()
if not path: