[incubator-gobblin] branch master updated: [GOBBLIN-1253] Update running jobs counter on Gobblin service restart[]

[suvasude]

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

suvasude pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new d1eca1a  [GOBBLIN-1253] Update running jobs counter on Gobblin service 
restart[]
d1eca1a is described below

commit d1eca1aa211093f5a46812959aba1ed354c3698d
Author: sv2000 <sudarsh...@gmail.com>
AuthorDate: Sat Aug 29 18:05:03 2020 -0700

    [GOBBLIN-1253] Update running jobs counter on Gobblin service restart[]
    
    Closes #3094 from sv2000/runningFlowsCounter
---
 .../org/apache/gobblin/service/modules/orchestration/DagManager.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
index 906251d..e84185f 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
@@ -527,6 +527,8 @@ public class DagManager extends AbstractIdleService {
       for (DagNode<JobExecutionPlan> dagNode : dag.getNodes()) {
         if (DagManagerUtils.getExecutionStatus(dagNode) == RUNNING) {
           addJobState(dagId, dagNode);
+          //Update the running jobs counter.
+          getRunningJobsCounter(dagNode).inc();
           isDagRunning = true;
         }
       }