Compare commits
1 Commits
e40d99bfe2
...
98671a9f92
Author | SHA1 | Date |
---|---|---|
p4u1 | 98671a9f92 |
|
@ -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()
|
||||
|
|
Loading…
Reference in New Issue