def GetProgressStatusGenerator(self):



    conn = sqlite3.connect(self.db_filename, isolation_level=None)
    cursor = conn.cursor()



    cursor.execute('select max(key_end) from progress')

    result = cursor.fetchone()
    if result is not None:
      key_end = result[0]
    else:
      logger.debug('No rows in progress database.')
      return

    self.prior_key_end = key_end



    cursor.execute(
        'select id, state, kind, key_start, key_end from progress'
        '  where state != ?'
        '  order by id',
        (STATE_SENT,))



    rows = cursor.fetchall()

    for row in rows:
      if row is None:
        break
      progress_key, state, kind, key_start, key_end = row

      yield progress_key, state, kind, key_start, key_end


    yield None, DATA_CONSUMED_TO_HERE, None, None, key_end
Get a generator which yields progress information.
dataset/ETHPy150Open GoogleCloudPlatform/python-compat-runtime/appengine-compat/exported_appengine_sdk/google/appengine/tools/bulkloader.py/_ProgressDatabase.GetProgressStatusGenerator