diff --git a/backend-node/src/services/flowExecutionService.ts b/backend-node/src/services/flowExecutionService.ts
index 53a181e3..dcaafb5b 100644
--- a/backend-node/src/services/flowExecutionService.ts
+++ b/backend-node/src/services/flowExecutionService.ts
@@ -360,7 +360,17 @@ export class FlowExecutionService {
         console.log(`📝 [updateStepData] Query: ${updateQuery}`);
         console.log(`📝 [updateStepData] Params:`, params);
         
-        await db.query(updateQuery, params);
+        // 트랜잭션으로 감싸서 사용자 ID 세션 변수 설정 후 업데이트 실행
+        // (트리거에서 changed_by를 기록하기 위함)
+        await db.query("BEGIN");
+        try {
+          await db.query(`SET LOCAL app.user_id = '${userId}'`);
+          await db.query(updateQuery, params);
+          await db.query("COMMIT");
+        } catch (txError) {
+          await db.query("ROLLBACK");
+          throw txError;
+        }
       }
 
       console.log(`✅ [updateStepData] Data updated successfully: ${tableName}.${primaryKeyColumn}=${recordId}`, {