callable

Author: Michal Tichák

core/environment/environment.go

@@ -669,6 +669,7 @@ func (env *Environment) handleHooks(workflow workflow.Role, trigger string, weig
 	metric := monitoring.NewMetric("hooks")
 	metric.AddTag("trigger", trigger)
 	metric.AddTag("envId", env.id.String())
+	metric.AddTag("runtype", env.GetRunType().String())
 	defer monitoring.TimerSendSingle(&metric, monitoring.Millisecond)()
 
 	allWeightsSet := make(callable.HooksMap)

core/workflow/callable/call.go

@@ -226,6 +226,7 @@ func (c *Call) Call() error {
 
 func (c *Call) newMetric(name string) monitoring.Metric {
 	metric := monitoring.NewMetric(name)
+	metric.AddTag("runtype", c.getRunTypeTag())
 	metric.AddTag("name", c.GetName())
 	metric.AddTag("trigger", c.GetTraits().Trigger)
 	metric.AddTag("envId", c.parentRole.GetEnvironmentId().String())
@@ -266,6 +267,17 @@ func (c *Call) Cancel() bool {
 	return false
 }
 
+func (c *Call) getRunTypeTag() string {
+	varStack, err := c.parentRole.ConsolidatedVarStack()
+	if err != nil {
+		return "nonexistent"
+	}
+	if rt, ok := varStack["run_type"]; ok {
+		return rt
+	}
+	return "nonexistent"
+}
+
 func (c *Call) GetParentRole() interface{} {
 	return c.parentRole
 }