diff --git a/pipeline_core/init.py b/pipeline_core/init.py
index 8fd5aa7..f9846f8 100644
--- a/pipeline_core/init.py
+++ b/pipeline_core/init.py
@@ -49,7 +49,7 @@ async def update_pipeline(params_kw):
             if not record_id:
                 result['message'] = '缺少id'
             else:
-                await sor.U('pipelines', data, {'id': record_id})
+                await sor.U('pipelines', {**data, 'id': record_id})
                 result['success'] = True
                 result['message'] = '更新成功'
     except Exception as e:
@@ -109,7 +109,7 @@ async def update_pipeline_step(params_kw):
             if not record_id:
                 result['message'] = '缺少id'
             else:
-                await sor.U('pipeline_steps', data, {'id': record_id})
+                await sor.U('pipeline_steps', {**data, 'id': record_id})
                 result['success'] = True
                 result['message'] = '更新成功'
     except Exception as e:
@@ -169,7 +169,7 @@ async def update_pipeline_version(params_kw):
             if not record_id:
                 result['message'] = '缺少id'
             else:
-                await sor.U('pipeline_versions', data, {'id': record_id})
+                await sor.U('pipeline_versions', {**data, 'id': record_id})
                 result['success'] = True
                 result['message'] = '更新成功'
     except Exception as e: