If you know the node that just completed you could check pipeline.grouped_nodes, it would not be the most efficient, but you could

release()

after you have moved completely passed all groups using a certain dataset.