From dfaf516d57b951576a93ba53263b884bc96044dc Mon Sep 17 00:00:00 2001 From: gearnode Date: Thu, 30 Jan 2025 16:03:08 -0800 Subject: [PATCH] Fix duplicated tasks Signed-off-by: gearnode --- pkg/probo/coredata/task.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/probo/coredata/task.go b/pkg/probo/coredata/task.go index 42efbf0ce..2d1357811 100644 --- 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())