Merge pull request cockroachdb#137 from crowdflux/flu_monitor_changes

Logic correction for running job managers
soniabhishek · Feb 5, 2017 · e1ff564 · e1ff564
2 parents d8988b6 + 060b4df
commit e1ff564
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/app/services/flu_svc/flu_monitor/flu_monitor.go b/app/services/flu_svc/flu_monitor/flu_monitor.go
@@ -55,12 +55,13 @@ func (fm *FluMonitor) getOrCreateProjectHandler(flu models.FeedLineUnit) Project
 		pHandler := NewProjectHandler(pc)
 
 		fm.bulkProcessor.AddJobManager(pHandler.jobManager)
-
 		fm.projectHandlers[flu.ProjectId] = pHandler
 
 		go pHandler.startFeedLineProcessor()
 		go pHandler.startCBUProcessor()
 
+		pHandler.jobManager.Run()
+
 		projectHandler = pHandler
 		plog.Info("Flu Monitor", "Project Handler Set", projectHandler.config.ProjectId)
 	}

diff --git a/bulk_processor/bulk_processor_test.go b/bulk_processor/bulk_processor_test.go
@@ -39,6 +39,7 @@ func TestDispatcher_Start(t *testing.T) {
 
 	for _, c := range clients {
 		dispatcher.AddJobManager(c.jobManager)
+		c.jobManager.Run()
 	}
 
 	dispatcher.Start()

diff --git a/bulk_processor/dispatcher.go b/bulk_processor/dispatcher.go
@@ -28,8 +28,6 @@ func (d *Dispatcher) Start() (started bool) {
 
 	d.startCheck()
 
-	runJobManagers(d.jobManagers)
-
 	d.startWorkers(d.maxWorkers)
 
 	go d.dispatch()