fix(drainer): increase jobs picked only when stream is not empty (#2958)

fix(drainer): increase jobs picked only when stream is not empty (#2958) #1746