I'm still a bit fuzzy on the proposal. It also seems at times like you two (David and Jarek) are sorta talking about two different things. David: "stream" syntax. Jarek: run operator in a task.
I would suggest @David maybe just produce a sort of draft AIP maybe in google docs or something and share and interested parties can review and understand better and possibly help shape the direction.