Compare commits

..

1 Commits

Author SHA1 Message Date
p4u1 98671a9f92 feat: abra app logs shows task errors
continuous-integration/drone/pr Build is passing Details
2023-12-12 18:01:03 +01:00
1 changed files with 15 additions and 15 deletions

View File

@ -95,23 +95,23 @@ func tailLogs(cl *dockerClient.Client, app config.App, serviceNames []string) er
var wg sync.WaitGroup
for _, service := range services {
wg.Add(1)
go func(serviceID, serviceName string) {
filters := filters.NewArgs()
filters.Add("name", serviceName)
tasks, err := cl.TaskList(context.Background(), types.TaskListOptions{Filters: f})
if err != nil {
logrus.Fatal(err)
}
if len(tasks) > 0 {
lastTask := tasks[len(tasks)-1].Status
if lastTask.State != swarm.TaskStateRunning {
for _, task := range tasks {
logrus.Errorf("Service %s: State %s: %s", serviceName, task.Status.State, task.Status.Err)
}
filters := filters.NewArgs()
filters.Add("name", service.Spec.Name)
tasks, err := cl.TaskList(context.Background(), types.TaskListOptions{Filters: f})
if err != nil {
logrus.Fatal(err)
}
if len(tasks) > 0 {
lastTask := tasks[len(tasks)-1].Status
if lastTask.State != swarm.TaskStateRunning {
for _, task := range tasks {
logrus.Errorf("Service %s: State %s: %s", service.Spec.Name, task.Status.State, task.Status.Err)
}
}
}
wg.Add(1)
go func(serviceID string) {
if internal.StdErrOnly {
logOpts.ShowStdout = false
}
@ -126,7 +126,7 @@ func tailLogs(cl *dockerClient.Client, app config.App, serviceNames []string) er
if err != nil && err != io.EOF {
logrus.Fatal(err)
}
}(service.ID, service.Spec.Name)
}(service.ID)
}
wg.Wait()