def _ingest_metadata(self, tag_templates_dict, assembled_entries):
        metadata_ingestor = ingest.DataCatalogMetadataIngestor(
            self._project_id, self._location_id, self._ENTRY_GROUP_ID)

        managed_tag_template = self._tag_template_factory.\
            get_tag_template_path(
                self._ENTRY_GROUP_ID)

        metadata_ingestor.ingest_metadata(
            assembled_entries, tag_templates_dict,
            {'delete_tags': {
                'managed_tag_template': managed_tag_template
            }})

        entries_count = len(assembled_entries)
        logging.info('==== %s entries synchronized!', entries_count)