File tree Expand file tree Collapse file tree 2 files changed +16
-0
lines changed
Expand file tree Collapse file tree 2 files changed +16
-0
lines changed Original file line number Diff line number Diff line change @@ -218,6 +218,7 @@ func (vs *VarStack) consolidated(stage Stage) (consolidatedStack map[string]stri
218218 if err != nil {
219219 return
220220 }
221+ case _STAGE_MAX :
221222 }
222223
223224 consolidated := gera .MakeMapWithMap (vs .Locals ).Wrap (gera .MakeMapWithMap (userVars ).Wrap (gera .MakeMapWithMap (vars ).Wrap (gera .MakeMapWithMap (defaults ))))
Original file line number Diff line number Diff line change @@ -1293,6 +1293,21 @@ func (m *Manager) handleMessage(tm *TaskmanMessage) error {
12931293 go m .updateTaskState (tm .taskId , tm .state )
12941294 case taskop .ReleaseTasks :
12951295 go m .releaseTasks (tm .GetEnvironmentId (), tm .GetTasks ())
1296+ case taskop .KillTasks :
1297+ log .WithPrefix ("taskman" ).
1298+ WithField ("partition" , tm .GetEnvironmentId ().String ()).
1299+ WithField ("level" , infologger .IL_Devel ).
1300+ WithField ("status" , tm .status .String ()).
1301+ WithField ("source" , tm .status .GetSource ().String ()).
1302+ WithField ("message" , tm .status .GetMessage ()).
1303+ Warn ("unexpected KillTasks message received" )
1304+ case taskop .Error :
1305+ log .WithPrefix ("taskman" ).
1306+ WithField ("partition" , tm .GetEnvironmentId ().String ()).
1307+ WithField ("level" , infologger .IL_Devel ).
1308+ WithField ("status" , tm .status .String ()).
1309+ WithField ("source" , tm .status .GetSource ().String ()).
1310+ Warn ("taskman received error: %s" , tm .GetError ())
12961311 }
12971312
12981313 return nil
You can’t perform that action at this time.
0 commit comments