docs: def ReleaseProcessedFlow(self, flow_obj):
      """Releases a flow that the worker was processing to the database."""
      key = (flow_obj.client_id, flow_obj.flow_id)
      next_id_to_process = flow_obj.next_request_to_process
      request_dict = self.flow_requests.get(key, {})
      if (next_id_to_process in request_dict and
          request_dict[next_id_to_process].needs_processing):
        return False
  
      self.UpdateFlow(
          flow_obj.client_id,
          flow_obj.flow_id,
          flow_obj=flow_obj,
          processing_on=None,
          processing_since=None,
          processing_deadline=None)
      return True