Hi,
I'm trying to make an aggregation that will end when several phrases are seen, but I can't tell in advance their incoming order, and I want to wait for all of them to arrive (until a minimal timeout.)
However, I don't want just to set a large timeout since I can wait too much time.
I think the best way would be to dynamically set the checking inside the aggregation, something like:
end_of_task => CheckIfShouldEndTask()
But I think that's not going to work.
I had the same problem also with when to start the aggregation, but for that there is a solution.
I set: map_action => "create_or_update"
so the aggregation begins when the earliest condition is met.
Is there a good way to end aggregation when the latest condition is met?
Thanks.