docs: def ReadHuntFlows(self,
                      hunt_id,
                      offset,
                      count,
                      filter_condition=db.HuntFlowsCondition.UNSET,
                      cursor=None):
      """Reads hunt flows matching given conditins."""
      hunt_id_int = db_utils.HuntIDToInt(hunt_id)
  
      query = ("SELECT {columns} FROM flows "
               "FORCE INDEX(flows_by_hunt) "
               "WHERE parent_hunt_id = %s AND parent_flow_id IS NULL "
               "{filter_condition} "
               "ORDER BY last_update ASC "
               "LIMIT %s OFFSET %s")
  
      filter_query, extra_args = self._HuntFlowCondition(filter_condition)
      query = query.format(
          columns=self.FLOW_DB_FIELDS, filter_condition=filter_query)
      args = [hunt_id_int] + extra_args + [count, offset]
  
      cursor.execute(query, args)
      return [self._FlowObjectFromRow(row) for row in cursor.fetchall()]