Fix duplicated tasks

Signed-off-by: gearnode <bryan@frimin.fr>
2025-01-30 16:03:08 -08:00
parent 31f750cf52
commit dfaf516d57
1 changed files with 2 additions and 1 deletions
--- a/pkg/probo/coredata/task.go
+++ b/pkg/probo/coredata/task.go
@@ -112,7 +112,8 @@ FROM
 INNER JOIN
    task_states ts ON ts.task_id = control_tasks.id
 WHERE
-    %s
+    ts.rank = 1
+    AND %s
 `

 	q = fmt.Sprintf(q, scope.SQLFragment(), cursor.SQLFragment())