def make_assembled_entries_list()

in google-datacatalog-apache-atlas-connector/src/google/datacatalog_connectors/apache_atlas/prepare/assembled_entry_factory.py [0:0]

• 27 lines of code
• 7 McCabe index (conditional complexity)

    def make_assembled_entries_list(self,
                                    metadata_dict,
                                    apache_entity_types=None):
        entity_types_dict = metadata_dict['entity_types']
        classifications = metadata_dict['classifications']
        enum_types_dict = metadata_dict['enum_types']

        assembled_entries = []
        for _, entity_type_dict in entity_types_dict.items():
            entity_type_name = entity_type_dict['name']
            if (apache_entity_types and
                entity_type_name in apache_entity_types) or \
                    apache_entity_types is None:

                logging.info('===> Processing entities for type: %s...',
                             entity_type_name)
                entities = entity_type_dict['entities']
                if entities:
                    for _, entity_dict in entities.items():
                        assembled_entries.append(
                            self.__make_assembled_entry_for_entity(
                                entity_dict, entity_types_dict,
                                classifications, enum_types_dict))
            else:
                logging.info(
                    '===> Ignoring entities for type: %s...,'
                    ' not in allowed list: %s', entity_type_name,
                    apache_entity_types)

        return assembled_entries