code: def _filter_deleted_records(self, batches):
          
          for batch in batches:
              for record in batch:
                  if not self.must_delete_record(record):
                      yield record
docs: Filter out deleted records