diff --git a/topik/intermediaries/digested_document_collection.py b/topik/intermediaries/digested_document_collection.py
index ce15826..0e1213a 100644
--- a/topik/intermediaries/digested_document_collection.py
+++ b/topik/intermediaries/digested_document_collection.py
@@ -42,4 +42,3 @@ def persistor(self):
     @property
     def filter_string(self):
         return self.corpus.filter_string
-
diff --git a/topik/intermediaries/raw_data.py b/topik/intermediaries/raw_data.py
index facf340..5c3bc17 100644
--- a/topik/intermediaries/raw_data.py
+++ b/topik/intermediaries/raw_data.py
@@ -227,7 +227,7 @@ def save(self, filename, saved_data=None):
         return super(ElasticSearchCorpus, self).save(filename, saved_data)
 
     def synchronize(self, max_wait, field):
-        # TODO: change this to a more general condition for wider use?
+        # TODO: change this to a more general condition for wider use, including read_input
         # could just pass in a string condition and then 'while not eval(condition)'
         count_not_yet_updated = -1
         while count_not_yet_updated != 0:
@@ -332,4 +332,4 @@ def save(self, filename, saved_data=None):
 
 def load_persisted_corpus(filename):
     corpus_dict = Persistor(filename).get_corpus_dict()
-    return output_formats[corpus_dict['class']](**corpus_dict["saved_data"])
\ No newline at end of file
+    return output_formats[corpus_dict['class']](**corpus_dict["saved_data"])