Skip to content

Commit

Permalink
Merge pull request #1386 from bstasyszyn/create_dids_to_file_progress
Browse files Browse the repository at this point in the history
test: Add progress logs to create_dids_to_file scenario
  • Loading branch information
bstasyszyn authored Jun 27, 2022
2 parents 93674f8 + d0d7255 commit 22158af
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
8 changes: 4 additions & 4 deletions test/bdd/did_orb_steps.go
Original file line number Diff line number Diff line change
Expand Up @@ -2020,7 +2020,7 @@ func (r *createDIDRequest) Invoke() (interface{}, error) {
resp, respErr = r.httpClient.Post(u, reqBytes, "application/json")
if respErr != nil {
if r.shouldRetry(nil, respErr) {
logger.Infof("Error posting request to [%s] on attempt %d: %s. Retrying in %s",
logger.Warnf("Error posting request to [%s] on attempt %d: %s. Retrying in %s",
u, i+1, respErr, r.backoff)

r.greylist.Add(u)
Expand All @@ -2030,7 +2030,7 @@ func (r *createDIDRequest) Invoke() (interface{}, error) {
continue
}

logger.Infof("Error posting request to [%s]: %s. Not retrying.", u, respErr)
logger.Errorf("Error posting request to [%s]: %s. Not retrying.", u, respErr)

return "", respErr
}
Expand All @@ -2042,12 +2042,12 @@ func (r *createDIDRequest) Invoke() (interface{}, error) {
}

if !r.shouldRetry(resp, nil) {
logger.Infof("Got HTTP response from [%s]: %d:%s. Not retrying.", u, resp.StatusCode, resp.ErrorMsg)
logger.Errorf("Got HTTP response from [%s]: %d:%s. Not retrying.", u, resp.StatusCode, resp.ErrorMsg)

return "", respErr
}

logger.Infof("Got HTTP response from [%s]: %d:%s. Retrying in %s", u, resp.StatusCode, resp.ErrorMsg, r.backoff)
logger.Warnf("Got HTTP response from [%s]: %d:%s. Retrying in %s", u, resp.StatusCode, resp.ErrorMsg, r.backoff)

time.Sleep(r.backoff)
}
Expand Down
4 changes: 2 additions & 2 deletions test/bdd/workerpool.go
Original file line number Diff line number Diff line change
Expand Up @@ -121,9 +121,9 @@ func (p *WorkerPool) listen() {

if len(p.responses)%100 == 0 {
if p.taskDescription != "" {
logger.Debugf("Got %d responses for task [%s]", len(p.responses), p.taskDescription)
logger.Warnf("Got %d responses for task [%s]", len(p.responses), p.taskDescription)
} else {
logger.Debugf("Got %d responses", len(p.responses))
logger.Warnf("Got %d responses", len(p.responses))
}
}
}
Expand Down

0 comments on commit 22158af

Please sign in to comment.