https://github.com/numaproj/numaflow-go/pull/111#discussion_r1537708110 This should apply to both session reducer and stream reducer.