fix(backend): lock rows that are being streamed to pipeline (#3073)

fix(backend): lock rows that are being streamed to pipeline (#3073) #753