[incubator-devlake] branch main updated: fix: pipeline stucks after first execution (#4015)

[likyh]

This is an automated email from the ASF dual-hosted git repository.

likyh pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-devlake.git


The following commit(s) were added to refs/heads/main by this push:
     new fce657de2 fix: pipeline stucks after first execution (#4015)
fce657de2 is described below

commit fce657de26e73c626df99c4feddbc6de7d3e2968
Author: Klesh Wong <zhenmian.hu...@merico.dev>
AuthorDate: Thu Dec 22 16:12:04 2022 +0800

    fix: pipeline stucks after first execution (#4015)
---
 services/pipeline.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/services/pipeline.go b/services/pipeline.go
index d94daeb04..341529600 100644
--- a/services/pipeline.go
+++ b/services/pipeline.go
@@ -166,7 +166,6 @@ func RunPipelineInQueue(pipelineMaxParallel int64) {
        sema := semaphore.NewWeighted(pipelineMaxParallel)
        runningParallelLabels := []string{}
        var runningParallelLabelLock sync.Mutex
-       dbPipeline := &models.DbPipeline{}
        for {
                globalPipelineLog.Info("acquire lock")
                // start goroutine when sema lock ready and pipeline exist.
@@ -176,6 +175,7 @@ func RunPipelineInQueue(pipelineMaxParallel int64) {
                        panic(err)
                }
                globalPipelineLog.Info("get lock and wait next pipeline")
+               dbPipeline := &models.DbPipeline{}
                for {
                        cronLocker.Lock()
                        // prepare query to find an appropriate pipeline to 
execute