async def METHOD_NAME(storage_client, cf_mgr, svc_name):
    asset_json = []
    plugin_value = await cf_mgr.get_category_item(svc_name, 'plugin')
    plugin = plugin_value['value'] if plugin_value is not None else ''
    payload = PayloadBuilder().SELECT(["asset", "plugin"]).WHERE(['service', '=', svc_name]).AND_WHERE(
        ['event', '=', 'Ingest']).AND_WHERE(['plugin', '=', plugin]).AND_WHERE(['deprecated_ts', 'isnull']).payload()
    try:
        result = await storage_client.query_tbl_with_payload('asset_tracker', payload)
        # TODO: FOGL-2549
        # old asset track entry still appears with combination of service name + plugin name + event name if exists
        asset_records = result['rows']
        assets = [ar["asset"].upper()for ar in asset_records]
        if len(assets):
            def map_original_asset_name(asset_stats_key):
                # asset name are being recorded in uppercase as key in statistics table
                for ar in asset_records:
                    if ar["asset"].upper() == asset_stats_key:
                        return ar["asset"]
                return None
            payload = PayloadBuilder().SELECT(["key", "value"]).WHERE(["key", "in", assets]).payload()
            results = await storage_client.query_tbl_with_payload("statistics", payload)
            for _r in results['rows']:
                asset_json.append({"count": _r['value'], "asset": map_original_asset_name(_r['key'])})
    except:
        raise
    else:
        return plugin, asset_json