From 2533e4f22e4e7628b1f76ec854c35a6634b45a63 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Fri, 29 May 2026 19:24:58 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E6=AD=A3=20SQLor=20=E6=8F=92?=
 =?UTF-8?q?=E5=85=A5=E6=96=B9=E6=B3=95=E8=B0=83=E7=94=A8=EF=BC=8Csor.I()?=
 =?UTF-8?q?=20=E6=94=B9=E4=B8=BA=20sor.C()?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 reallife_asset/init.py | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

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,