Ignore schedules without a replica setting

internal/agent/scale.go

@@ -120,6 +120,11 @@ func (a *worker) scale(e *event) {
 		return
 	}
 	// regular scaling
+	if !e.sched.HasReplicas() {
+		// ignore scalling if no replicas are present, this is probably a
+		// schedule just containing triggers.
+		return
+	}
 	repl, err := e.sched.GetReplicas()
 	if err == nil {
 		err = e.obj.Scale(e.state, repl)

internal/schedule/attribute.go

@@ -16,6 +16,13 @@ func (s *Schedule) GetReplicas() (int, error) {
 	return strconv.Atoi(r)
 }
 
+// HasReplicas checks if the given schedule has a replicas settings that
+// should be applied.
+func (s *Schedule) HasReplicas() bool {
+	_, ok := s.settings["replicas"]
+	return ok
+}
+
 // GetState will return the state that should be applied according to the
 // schedule.
 func (s *Schedule) GetState() (State, error) {

internal/schedule/attribute_test.go

@@ -51,6 +51,34 @@ func TestGetReplicas(t *testing.T) {
 	}
 }
 
+func TestHasReplicas(t *testing.T) {
+	tests := []struct {
+		res   bool
+		sched *Schedule
+	}{
+		{
+			res: true,
+			sched: &Schedule{
+				settings: map[string]string{
+					"replicas": "1",
+				},
+			},
+		},
+		{
+			res: false,
+			sched: &Schedule{
+				settings: map[string]string{},
+			},
+		},
+	}
+	for i, tst := range tests {
+		r := tst.sched.HasReplicas()
+		if r != tst.res {
+			t.Errorf("failed test %d; expected %t , got %t", i, tst.res, r)
+		}
+	}
+}
+
 func TestGetState(t *testing.T) {
 	tests := []struct {
 		state State