diff --git a/discount/init.py b/discount/init.py
index b603d77..641d47a 100644
--- a/discount/init.py
+++ b/discount/init.py
@@ -124,7 +124,7 @@ where resellerid = ${resellerid}$
 		"customerid": customerid,
 		"biz_date": biz_date
 	}
-	recs = await sqlExe(sql, ns)
+	recs = await sor.sqlExe(sql, ns)
 	if not recs:
 		return await sor_get_star_discount(sor, resellerid, biz_date)