diff --git a/reallife_asset/init.py b/reallife_asset/init.py
index 27bf7c3..cbf9ee0 100644
--- a/reallife_asset/init.py
+++ b/reallife_asset/init.py
@@ -90,7 +90,7 @@ async def rl_create_validate_session(org_id, vendor, callback_url,
     async with db.sqlorContext(dbname) as sor:
         gid = getID()
         now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-        await sor.I("rl_asset_group", {
+        await sor.C("rl_asset_group", {
             "id": gid,
             "org_id": org_id,
             "vendor": vendor,
@@ -189,7 +189,7 @@ async def rl_create_asset(org_id, vendor_group_id, source_url,
     asset_uri = f"asset://{vendor_asset_id}" if vendor_asset_id else ""
 
     async with db.sqlorContext(dbname) as sor:
-        await sor.I("rl_asset", {
+        await sor.C("rl_asset", {
             "id": asset_id,
             "org_id": org_id,
             "group_id": local_group_id,
@@ -344,7 +344,7 @@ async def rl_sync_group_from_vendor(org_id, vendor, project_name="default"):
                 }, {"id": existing[0].id})
             else:
                 gid = getID()
-                await sor.I("rl_asset_group", {
+                await sor.C("rl_asset_group", {
                     "id": gid,
                     "org_id": org_id,
                     "vendor": vendor,
@@ -408,7 +408,7 @@ async def rl_sync_assets_from_vendor(org_id, local_group_id):
                 }, {"id": existing[0].id})
             else:
                 aid = getID()
-                await sor.I("rl_asset", {
+                await sor.C("rl_asset", {
                     "id": aid,
                     "org_id": org_id,
                     "group_id": local_group_id,
@@ -455,7 +455,7 @@ async def rl_verify_user(org_id, user_id, vendor, project_name="default"):
     now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
     db = DBPools()
     async with db.sqlorContext(_get_dbname()) as sor:
-        await sor.I("rl_asset_group", {
+        await sor.C("rl_asset_group", {
             "id": gid,
             "org_id": org_id,
             "vendor": vendor,
@@ -514,7 +514,7 @@ async def rl_upload_user(org_id, vendor_group_id, source_url, asset_type, name,
     asset_uri = f"asset://{vendor_asset_id}" if vendor_asset_id else ""
 
     async with db.sqlorContext(dbname) as sor:
-        await sor.I("rl_asset", {
+        await sor.C("rl_asset", {
             "id": asset_id,
             "org_id": org_id,
             "group_id": local_group_id,
@@ -638,7 +638,7 @@ async def rl_handle_callback(byted_token, project_name="default"):
                 "update_time": now,
             }, {"id": existing[0].id})
         else:
-            await sor.I("rl_org_group", {
+            await sor.C("rl_org_group", {
                 "id": mapping_id,
                 "org_id": org_id,
                 "vendor": vendor,