@@ -132,21 +132,24 @@ func RotateTasks(event string, silent bool) error {
132
132
fmt .Println ("---" )
133
133
}
134
134
cChecks := GetCommonChecks ()
135
- err := runTasksRotator (cChecks , event , silent )
135
+ rotatedCount , err := runTasksRotator (cChecks , event , silent )
136
136
if err != nil {
137
137
fmt .Println (err )
138
+ } else if rotatedCount == 0 {
139
+ // avoid running constantly if no tasks are installed
140
+ time .Sleep (60 * time .Second )
138
141
}
139
142
140
143
time .Sleep (5 * time .Second )
141
144
}
142
145
}
143
146
144
147
// runTasksRotator checks which tasks should be run and starts rotating
145
- func runTasksRotator (cChecks * CommonChecks , event string , silent bool ) error {
148
+ func runTasksRotator (cChecks * CommonChecks , event string , silent bool ) ( int , error ) {
146
149
var err error
147
150
CurrentQueue , err = ListTasksDetailed ()
148
151
if err != nil {
149
- return err
152
+ return 0 , err
150
153
}
151
154
152
155
rotatedN := 0
@@ -158,7 +161,7 @@ func runTasksRotator(cChecks *CommonChecks, event string, silent bool) error {
158
161
err = t .Run ()
159
162
if err != nil {
160
163
rotatedNFails ++
161
- return err
164
+ return 0 , err
162
165
}
163
166
}
164
167
@@ -172,7 +175,7 @@ func runTasksRotator(cChecks *CommonChecks, event string, silent bool) error {
172
175
fmt .Printf ("Rotated %d tasks, %d failed, %d success\n " , rotatedN , rotatedNFails , rotatedNSuccess )
173
176
}
174
177
175
- return nil
178
+ return rotatedN , nil
176
179
}
177
180
178
181
// saveTasksRotatorRunning saves that the rotator is running
0 commit comments