|
|
@@ -81,7 +81,8 @@ func GetQueuesDetail() (*map[string]int, error) { |
|
|
|
var jobResult models.QueueDetailResult |
|
|
|
|
|
|
|
var result = make(map[string]int, 0) |
|
|
|
|
|
|
|
retry := 0 |
|
|
|
sendjob: |
|
|
|
res, err := client.R(). |
|
|
|
SetHeader("Content-Type", "application/json"). |
|
|
|
SetAuthToken(TOKEN). |
|
|
@@ -92,6 +93,12 @@ func GetQueuesDetail() (*map[string]int, error) { |
|
|
|
return nil, fmt.Errorf("resty get queues detail failed: %s", err) |
|
|
|
} |
|
|
|
|
|
|
|
if jobResult.Code == errInvalidToken && retry < 1 { |
|
|
|
retry++ |
|
|
|
_ = loginCloudbrain() |
|
|
|
goto sendjob |
|
|
|
} |
|
|
|
|
|
|
|
if jobResult.Code != Success { |
|
|
|
return nil, fmt.Errorf("jobResult err: %s", res.String()) |
|
|
|
} |
|
|
|