@@ -193,10 +193,12 @@ func (ssn *Session) Pipeline(task *api.TaskInfo, hostname string) error {
193
193
if err := job .UpdateTaskStatus (task , api .Pipelined ); err != nil {
194
194
glog .Errorf ("Failed to update task <%v/%v> status to %v in Session <%v>: %v" ,
195
195
task .Namespace , task .Name , api .Pipelined , ssn .UID , err )
196
+ return err
196
197
}
197
198
} else {
198
199
glog .Errorf ("Failed to found Job <%s> in Session <%s> index when binding." ,
199
200
task .Job , ssn .UID )
201
+ return fmt .Errorf ("failed to find job %s when binding" , task .Job )
200
202
}
201
203
202
204
task .NodeName = hostname
@@ -205,12 +207,14 @@ func (ssn *Session) Pipeline(task *api.TaskInfo, hostname string) error {
205
207
if err := node .AddTask (task ); err != nil {
206
208
glog .Errorf ("Failed to add task <%v/%v> to node <%v> in Session <%v>: %v" ,
207
209
task .Namespace , task .Name , hostname , ssn .UID , err )
210
+ return err
208
211
}
209
212
glog .V (3 ).Infof ("After added Task <%v/%v> to Node <%v>: idle <%v>, used <%v>, releasing <%v>" ,
210
213
task .Namespace , task .Name , node .Name , node .Idle , node .Used , node .Releasing )
211
214
} else {
212
215
glog .Errorf ("Failed to found Node <%s> in Session <%s> index when binding." ,
213
216
hostname , ssn .UID )
217
+ return fmt .Errorf ("failed to find node %s" , hostname )
214
218
}
215
219
216
220
for _ , eh := range ssn .eventHandlers {
@@ -295,10 +299,12 @@ func (ssn *Session) dispatch(task *api.TaskInfo) error {
295
299
if err := job .UpdateTaskStatus (task , api .Binding ); err != nil {
296
300
glog .Errorf ("Failed to update task <%v/%v> status to %v in Session <%v>: %v" ,
297
301
task .Namespace , task .Name , api .Binding , ssn .UID , err )
302
+ return err
298
303
}
299
304
} else {
300
305
glog .Errorf ("Failed to found Job <%s> in Session <%s> index when binding." ,
301
306
task .Job , ssn .UID )
307
+ return fmt .Errorf ("failed to find job %s" , task .Job )
302
308
}
303
309
304
310
metrics .UpdateTaskScheduleDuration (metrics .Duration (task .Pod .CreationTimestamp .Time ))
@@ -316,17 +322,20 @@ func (ssn *Session) Evict(reclaimee *api.TaskInfo, reason string) error {
316
322
if err := job .UpdateTaskStatus (reclaimee , api .Releasing ); err != nil {
317
323
glog .Errorf ("Failed to update task <%v/%v> status to %v in Session <%v>: %v" ,
318
324
reclaimee .Namespace , reclaimee .Name , api .Releasing , ssn .UID , err )
325
+ return err
319
326
}
320
327
} else {
321
328
glog .Errorf ("Failed to found Job <%s> in Session <%s> index when binding." ,
322
329
reclaimee .Job , ssn .UID )
330
+ return fmt .Errorf ("failed to find job %s" , reclaimee .Job )
323
331
}
324
332
325
333
// Update task in node.
326
334
if node , found := ssn .Nodes [reclaimee .NodeName ]; found {
327
335
if err := node .UpdateTask (reclaimee ); err != nil {
328
336
glog .Errorf ("Failed to update task <%v/%v> in Session <%v>: %v" ,
329
337
reclaimee .Namespace , reclaimee .Name , ssn .UID , err )
338
+ return err
330
339
}
331
340
}
332
341
0 commit comments