Skip to content
This repository has been archived by the owner on Nov 8, 2022. It is now read-only.

Commit

Permalink
Renamed vars (sub_errs -> sers, unsub_errs -> uerrs)
Browse files Browse the repository at this point in the history
  • Loading branch information
andrzej-k committed Dec 8, 2015
1 parent cbe7e21 commit b8d6e7c
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions scheduler/scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -326,11 +326,11 @@ func (s *scheduler) startTask(id, source string) []serror.SnapError {

mts, plugins := s.gatherMetricsAndPlugins(t.workflow)
cps := returnCorePlugin(plugins)
sub_errs := s.metricManager.SubscribeDeps(t.ID(), mts, cps)
if len(sub_errs) > 0 {
serrs := s.metricManager.SubscribeDeps(t.ID(), mts, cps)
if len(serrs) > 0 {
// Tear down plugin processes started so far.
unsub_errs := s.metricManager.UnsubscribeDeps(t.ID(), mts, cps)
errs := append(sub_errs, unsub_errs...)
uerrs := s.metricManager.UnsubscribeDeps(t.ID(), mts, cps)
errs := append(serrs, uerrs...)
logger.WithFields(log.Fields{
"task-id": t.ID(),
"_error": errs,
Expand Down

0 comments on commit b8d6e7c

Please sign in to comment.