fix(streams): restore realtime stream writing for v3 tasks (#2675)

fix(streams): restore realtime stream writing for v3 tasks (#2675) #2551