#432 done. (#431 related)

arekit/common/data/input/providers/const.py

@@ -0,0 +1,3 @@
+# Idle mode related to iteration format, which is considered only for assessing the expected
+# amount of sampled data, while its contents could be avoided at all.
+IDLE_MODE = "idle_mode"

arekit/common/data/input/providers/opinions.py

@@ -1,3 +1,4 @@
+from arekit.common.data.input.providers.const import IDLE_MODE
 from arekit.common.linkage.text_opinions import TextOpinionsLinkage
 from arekit.common.pipeline.base import BasePipeline
 from arekit.common.text_opinions.base import TextOpinion
@@ -28,9 +29,9 @@ def __assign_ids(self, linkage):
             self.__current_id += 1
 
     # TODO. rename.
-    def iter_linked_opinions(self, doc_ids):
+    def iter_linked_opinions(self, doc_ids, idle_mode=False):
         self.__current_id = 0
-        for linkage in self.__pipeline.run(doc_ids):
+        for linkage in self.__pipeline.run(doc_ids, params_dict={IDLE_MODE: idle_mode}):
             assert(isinstance(linkage, TextOpinionsLinkage))
             self.__assign_ids(linkage)
             yield linkage

arekit/common/data/input/providers/rows/base.py

@@ -28,7 +28,7 @@ def iter_by_rows(self, opinion_provider, doc_ids_iter, idle_mode):
         assert(isinstance(opinion_provider, InputTextOpinionProvider))
         assert(isinstance(doc_ids_iter, collections.Iterable))
 
-        for linkage in opinion_provider.iter_linked_opinions(doc_ids_iter):
+        for linkage in opinion_provider.iter_linked_opinions(doc_ids=doc_ids_iter, idle_mode=idle_mode):
             assert(isinstance(linkage, TextOpinionsLinkage))
             assert(isinstance(linkage.Tag, ParsedNewsService))