def run()

in google-datacatalog-hive-connector/app.py [0:0]

• 17 lines of code
• 3 McCabe index (conditional complexity)

def run():

    if request.method == 'POST':
        request_data = request.get_json()
        app.logger.info(request_data)

        message = request_data['message']
        data = message['data']
        sync_event = json.loads(base64.b64decode(data).decode('utf-8'))

        datacatalog_synchronizer.DataCatalogSynchronizer(
            project_id=os.environ['HIVE2DC_DATACATALOG_PROJECT_ID'],
            location_id=os.environ['HIVE2DC_DATACATALOG_LOCATION_ID'],
            hive_metastore_db_host=os.
            environ['HIVE2DC_HIVE_METASTORE_DB_HOST'],
            metadata_sync_event=sync_event).run()

        response = {'message': 'Synchronized', 'code': 'SUCCESS'}
        return make_response(jsonify(response), 200)
    elif request.method == 'GET':
        return 'use POST method with a message event BODY'