Is there a way to process the results of a task as they complete? For instance, I have many tasks doing data processing on chunks of a dataframe and I want to aggregate the results of the tasks into an array as they complete. Because I want to operate on the aggregated results, I want this operation to be in the flow and not in the task itself. The closest I can find is this post from @Michael Adkins a few years ago but I’m wondering if anything has changed.

Hey Derek - this is being worked on here: https://github.com/PrefectHQ/prefect/pull/14641