env = request._run_ns
async with get_sor_context(env, 'llmage') as sor:
	sql = "select * from llmusage where status='SUCCEEDED' and accounting_status != 'accounted'"
	recs = await sor.sqlExe(sql, {})
	for r in recs:
		try:
			x = await llm_accounting(request, r)
		except Exception as e:
			exception(f'{r.id=} accounting error')