code: def _handle_streamer_finished(self, index, succeeded, highest_ack):
          
  
          self._logger.debug("Rolling back streamer %d after streaming, highest ack from streaming subsystem was %d", index, highest_ack)
          self.acknowledge_streamer(index, highest_ack, False)
docs: Callback when a streamer finishes processing.