数据修复脚本

@@ -5,13 +5,13 @@ WITH t_node_task AS (
         *
     FROM (
         SELECT
-            row_number() OVER (PARTITION BY project_id) AS row_id,
+            row_number() OVER (PARTITION BY project_id,
+                node_type) AS row_id,
         *
     FROM
         node_task
     WHERE
-        cycle_id = 1653724699349225472
-        AND node_type = 1) AS t_node_task
+        cycle_id = 1653724699349225472) AS t_node_task
     WHERE
         row_id = 1
     ORDER BY