code: def reindex(pid_type):
      
      click.secho('Sending records to indexing queue ...', fg='green')
  
      query = (x[0] for x in PersistentIdentifier.query.filter_by(
          object_type='rec', status=PIDStatus.REGISTERED
      ).filter(
          PersistentIdentifier.pid_type.in_(pid_type)
      ).values(
          PersistentIdentifier.object_uuid
      ))
      RecordIndexer().bulk_index(query)
      click.secho('Execute "run" command to process the queue!',
                  fg='yellow')
docs: Reindex all records.
  
      :param pid_type: Pid type.