Describe the bug
analyse_texts returns results only after all data has been processed - but it should already start returning results as the data is being processed.
To Reproduce
from averbis import Client
import time
client = Client("MYPROFILE")
project = client.get_project("PROJECT")
pipeline = project.get_pipeline("PIPELINE").ensure_started()
start = time.time()
count = 0
for r in pipeline.analyse_texts([f"This is document {k}" for k in range(50)]):
elapsed = time.time() - start
print(f"{count=}, {elapsed=}")
count += 1
The for loop is run only after all data has been processed:
Describe the bug analyse_texts returns results only after all data has been processed - but it should already start returning results as the data is being processed.
To Reproduce
The for loop is run only after all data has been processed:
Expected behavior The for loop should proceed as data is being processed - the elapsed time should be clearly different.
Please complete the following information: