Zero length batches in the stream graph executor go through the pipeline end will eventually be yielded.
We might want to just discard them (i.e. not add them to the input queue of subsequent tasks or yield), since they don't seem to have much meaning and require book keeping and serde etc.
Zero length batches in the stream graph executor go through the pipeline end will eventually be yielded.
We might want to just discard them (i.e. not add them to the input queue of subsequent tasks or yield), since they don't seem to have much meaning and require book keeping and serde etc.