Skip to content
This repository has been archived by the owner on Jun 12, 2024. It is now read-only.

Commit

Permalink
Fix metrics in workers, make task worker more efficient (#62)
Browse files Browse the repository at this point in the history
* Now worker (task/schedule) metrics are consistent with queue metrics
* Task worker now handles multiple tasks in one iteration before
  waiting for an interval
* Removed metrics which didn't make sense
* Fixed linter issues
  • Loading branch information
rdner authored Sep 28, 2020
1 parent ef32794 commit 551a54e
Show file tree
Hide file tree
Showing 7 changed files with 522 additions and 361 deletions.
4 changes: 2 additions & 2 deletions pkg/db/open.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,15 +41,15 @@ func Open(ctx context.Context, cfg config.Database) (db *sql.DB, err error) {
db, err = sql.Open(cfg.DriverName, connStr)
if err != nil {
errMsg := fmt.Sprintf("failed to open db connection: %s", err)
span.LogEvent(errMsg)
span.LogKV("error", errMsg)
logrus.Errorf(errMsg)
return err
}

err = db.Ping()
if err != nil {
errMsg := fmt.Sprintf("failed to ping target db: %s", err)
span.LogEvent(errMsg)
span.LogKV("error", errMsg)
logrus.Errorf(errMsg)
return err
}
Expand Down
Loading

0 comments on commit 551a54e

Please sign in to comment.