code: def Terminate(self, status=None):
      
      try:
        self.queue_manager.DestroyFlowStates(self.session_id)
      except queue_manager.MoreDataException:
        pass
  
      # This flow might already not be running.
      if not self.IsRunning():
        return
  
      self._SendTerminationMessage(status=status)
  
      # Mark as terminated.
      self.context.state = rdf_flow_runner.FlowContext.State.TERMINATED
      self.flow_obj.Flush()
docs: Terminates this flow.