diff --git a/pipeline_core/init.py b/pipeline_core/init.py
index 3bbfb57..8fd5aa7 100644
--- a/pipeline_core/init.py
+++ b/pipeline_core/init.py
@@ -239,7 +239,7 @@ async def publish_pipeline(params_kw):
             await sor.C('pipeline_versions', version_data)
 
             # Update pipeline status to published
-            await sor.U('pipelines', {'status': 'published'}, {'id': pipeline_id})
+            await sor.U('pipelines', {'id': pipeline_id, 'status': 'published'})
 
             result['success'] = True
             result['message'] = '发布成功'