code: def WriteFlowResults(self, results, cursor=None):
      
      query = ("INSERT INTO flow_results "
               "(client_id, flow_id, hunt_id, timestamp, payload, type, tag) "
               "VALUES ")
      templates = []
  
      args = []
      for r in results:
        templates.append("(%s, %s, %s, FROM_UNIXTIME(%s), %s, %s, %s)")
        args.append(db_utils.ClientIDToInt(r.client_id))
        args.append(db_utils.FlowIDToInt(r.flow_id))
        if r.hunt_id:
          args.append(db_utils.HuntIDToInt(r.hunt_id))
        else:
          args.append(0)
        args.append(
            mysql_utils.RDFDatetimeToTimestamp(rdfvalue.RDFDatetime.Now()))
        args.append(r.payload.SerializeToString())
        args.append(compatibility.GetName(r.payload.__class__))
        args.append(r.tag)
  
      query += ",".join(templates)
  
      try:
        cursor.execute(query, args)
      except MySQLdb.IntegrityError as e:
        raise db.AtLeastOneUnknownFlowError(
            [(r.client_id, r.flow_id) for r in results], cause=e)
docs: Writes flow results for a given flow.