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