d8dfun/virtual-kubelet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Fargate: Handle describe failure and log failure reason

Browse Source
This commit is contained in:
Onur Filiz
2018-05-03 14:13:21 -07:00
committed by Onur Filiz
parent 18adde2aca
commit b96181afa8
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
providers/aws/fargate/pod.go
View File

@@ -195,6 +195,9 @@ func (pod *Pod) Start() error {
runTaskOutput, err := api.RunTask(runTaskInput) runTaskOutput, err := api.RunTask(runTaskInput)
log.Printf("RunTask err:%+v output:%+v", err, runTaskOutput) log.Printf("RunTask err:%+v output:%+v", err, runTaskOutput)
if err != nil || len(runTaskOutput.Tasks) == 0 { if err != nil || len(runTaskOutput.Tasks) == 0 {
if len(runTaskOutput.Failures) != 0 {
err = fmt.Errorf("reason: %s", *runTaskOutput.Failures[0].Reason)
}
err = fmt.Errorf("failed to run task: %v", err) err = fmt.Errorf("failed to run task: %v", err)
return err return err
} }
@@ -332,7 +335,11 @@ func (pod *Pod) describe() (*ecs.Task, error) {
} }
describeTasksOutput, err := api.DescribeTasks(describeTasksInput) describeTasksOutput, err := api.DescribeTasks(describeTasksInput)
if err != nil { if err != nil || len(describeTasksOutput.Tasks) == 0 {
if len(describeTasksOutput.Failures) != 0 {
err = fmt.Errorf("reason: %s", *describeTasksOutput.Failures[0].Reason)
}
err = fmt.Errorf("failed to describe task: %v", err)
return nil, err return nil, err
} }