ns = params_kw.copy()

sql1 = """select sum(input_tokens + output_tokens) as tokens, modelinstanceid, modeltypeid, transdate 
from feelog 
where pricing_mode = 'token' 
	and transdate >= ${start_date}$ 
	and transdate < ${end_date}$ 
group by transdate, modelinstanceid, modeltypeid"""

sql = f"""select a.*, b.name as miname, c.name as modeltypename, concat(b.name, '(', c.name , ')') as name
from ({sql1}) a 
	left join modelinstance b on a.modelinstanceid=b.id
	left join modeltype c on a.modeltypeid = c.id
where tokens > 10000
order by a.tokens desc"""
info(f'{sql=}, {ns=}')
db = DBPools()
async with db.sqlorContext('sage') as sor:
	r = await sor.sqlExe(sql, ns.copy())
	info(f"daily_total_usage.dspy:{ns=}, return {r=}")
	return r
exception(f"daily_total_usage.dspy:{sql=}, {ns=}, exception happend")
return []