diff --git a/packages/plugins/@nocobase/plugin-workflow-manual/src/server/migrations/20250227220712-add-pending-tasks.ts b/packages/plugins/@nocobase/plugin-workflow-manual/src/server/migrations/20250227220712-add-pending-tasks.ts
index ecff8ac176..50f0b7ae7b 100644
--- a/packages/plugins/@nocobase/plugin-workflow-manual/src/server/migrations/20250227220712-add-pending-tasks.ts
+++ b/packages/plugins/@nocobase/plugin-workflow-manual/src/server/migrations/20250227220712-add-pending-tasks.ts
@@ -26,17 +26,17 @@ export default class extends Migration {
         },
         transaction,
       });
-      await WorkflowTaskModel.bulkCreate(
-        tasks.map((item) => ({
-          type: MANUAL_TASK_TYPE,
-          key: `${item.id}`,
-          userId: item.userId,
-          workflowId: item.workflowId,
-        })),
-        {
+      const records = tasks.map((item) => ({
+        type: MANUAL_TASK_TYPE,
+        key: `${item.id}`,
+        userId: item.userId,
+        workflowId: item.workflowId,
+      }));
+      for (const record of records) {
+        await WorkflowTaskModel.upsert(record, {
           transaction,
-        },
-      );
+        });
+      }
     });
   }
 }