pep8

feedly/feed_managers/base.py

@@ -294,7 +294,8 @@ def create_fanout_tasks(self, follower_ids, feed_class, operation, operation_kwa
         :param operation_kwargs: kwargs passed to the operation
         :param fanout_priority: the priority set to this fanout
         '''
-        fanout_task = self.get_fanout_task(fanout_priority, feed_class=feed_class)
+        fanout_task = self.get_fanout_task(
+            fanout_priority, feed_class=feed_class)
         if not fanout_task:
             return []
         chunk_size = self.fanout_chunk_size
@@ -381,7 +382,8 @@ def batch_import(self, user_id, activities, fanout=True, chunk_size=500):
             # now start a big fanout task
             if fanout:
                 logger.info('starting task fanout for chunk %s', index)
-                follower_ids_by_prio = self.get_user_follower_ids(user_id=user_id)
+                follower_ids_by_prio = self.get_user_follower_ids(
+                    user_id=user_id)
                 # create the fanout tasks
                 operation_kwargs = dict(activities=activity_chunk, trim=False)
                 for feed_class in self.feed_classes.values():

feedly/storage/cassandra/timeline_storage.py

@@ -84,7 +84,8 @@ def trim(self, key, length, batch_interface=None):
             return
         last_activity = trim_slice[-1]
         if last_activity:
-            qs = self.model.filter(feed_id=key, activity_id__lt=last_activity[0]).values_list('activity_id')
+            qs = self.model.filter(
+                feed_id=key, activity_id__lt=last_activity[0]).values_list('activity_id')
             for values in qs.order_by('-activity_id').limit(self.trim_limit):
                 activity_id = values[0]
                 self.model(feed_id=key, activity_id=activity_id).batch(

feedly/tests/settings.py

@@ -18,4 +18,3 @@
         'password': None
     },
 }
-