def __run_event_metadata_hook()

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

• 16 lines of code
• 1 McCabe index (conditional complexity)

    def __run_event_metadata_hook(cls, args):
        atlas_entity_types = cls.__get_atlas_entity_types(args)

        sync.MetadataEventSynchronizer(
            datacatalog_project_id=args.datacatalog_project_id,
            datacatalog_location_id=cls.__DATACATALOG_LOCATION_ID,
            atlas_connection_args={
                'host': args.atlas_host,
                'port': args.atlas_port,
                'user': args.atlas_user,
                'pass': args.atlas_passsword,
                'event_servers': args.event_servers.split(','),
                'event_consumer_group_id': args.event_consumer_group_id,
                'event_hook': True
            },
            atlas_entity_types=atlas_entity_types,
            enable_monitoring=args.enable_monitoring).run()