Stream-based task workflow