def process_event()

in functions/source/association-updater/handler.py [0:0]

• 12 lines of code
• 6 McCabe index (conditional complexity)

def process_event(event, integration_points):
    cache_ids = get_cache_ids(event, integration_points)
    if cache_ids and cache_ids.get('child') and cache_ids.get('parent'):
        child_asset = assets_cache.get(cache_ids.get('child'))
        parent_asset = assets_cache.get(cache_ids.get('parent'))

        if child_asset is None:
            logger.warn(f"Asset with id={cache_ids.get('child')} isn't found.")
            return

        if parent_asset is None:
            logger.error(f"No parent asset with id={cache_ids.get('parent')} found for {cache_ids.get('child')}")
            return

        association_converter.associate_asset(parent_asset, child_asset)