def get_database_metadata()

in google-datacatalog-hive-connector/src/google/datacatalog_connectors/hive/scrape/metadata_sync_event_scraper.py [0:0]

• 20 lines of code
• 9 McCabe index (conditional complexity)

    def get_database_metadata(cls, message):
        event = message.get('event')
        if not event:
            raise Exception('Message does not contain a event type')

        if event not in [event.name for event in sync_event.SyncEvent]:
            raise Exception('Unsupported event type: {}'.format(event))

        if event == sync_event.SyncEvent.CREATE_TABLE.name:
            return cls.__build_metadata_entities_for_create_table_event(
                message)

        if event == sync_event.SyncEvent.ALTER_TABLE.name:
            return cls.__build_metadata_entities_for_update_table_event(
                message)

        if event == sync_event.SyncEvent.CREATE_DATABASE.name:
            return cls.__build_metadata_entities_for_create_database_event(
                message)

        if event == sync_event.SyncEvent.DROP_TABLE.name:
            return cls.__build_metadata_entities_for_drop_table_event(message)

        if event == sync_event.SyncEvent.DROP_DATABASE.name:
            return cls.__build_metadata_entities_for_drop_database_event(
                message)