You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@devlake.apache.org by ab...@apache.org on 2023/08/18 07:32:58 UTC
[incubator-devlake] branch release-v0.18 updated: fix: rerun failed with LOCK TABLE (#5910) (#5911)
This is an automated email from the ASF dual-hosted git repository.
abeizn pushed a commit to branch release-v0.18
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git
The following commit(s) were added to refs/heads/release-v0.18 by this push:
new e32f076ae fix: rerun failed with LOCK TABLE (#5910) (#5911)
e32f076ae is described below
commit e32f076ae238324c0eacee86a778d0c0a862e1d0
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Fri Aug 18 15:32:54 2023 +0800
fix: rerun failed with LOCK TABLE (#5910) (#5911)
Co-authored-by: Klesh Wong <zh...@merico.dev>
---
backend/server/services/pipeline.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/backend/server/services/pipeline.go b/backend/server/services/pipeline.go
index 1a1f3006a..3c8daa50d 100644
--- a/backend/server/services/pipeline.go
+++ b/backend/server/services/pipeline.go
@@ -503,7 +503,7 @@ func RerunPipeline(pipelineId uint64, task *models.Task) (tasks []*models.Task,
for _, t := range failedTasks {
// mark previous task failed
t.Status = models.TASK_FAILED
- err := tx.UpdateColumn(t, "status", models.TASK_FAILED)
+ err := db.UpdateColumn(t, "status", models.TASK_FAILED)
if err != nil {
return nil, err
}